File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ def __init__(
34
34
if isinstance (spark_options , JobConfiguration ):
35
35
self ._spark_options = spark_options
36
36
elif isinstance (spark_options , dict ):
37
- self ._spark_options = JobConfiguration (** spark_options if spark_options else {}). to_dict ()
37
+ self ._spark_options = JobConfiguration (** spark_options if spark_options else {})
38
38
39
39
def to_dict (self ):
40
40
return {
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ def __init__(
37
37
if isinstance (spark_job_configuration , JobConfiguration ):
38
38
self ._spark_job_configuration = spark_job_configuration
39
39
elif isinstance (spark_job_configuration , dict ):
40
- self ._spark_job_configuration = JobConfiguration (** spark_job_configuration if spark_job_configuration else {}). to_dict ()
40
+ self ._spark_job_configuration = JobConfiguration (** spark_job_configuration if spark_job_configuration else {})
41
41
42
42
@property
43
43
def data_format (self ):
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ def __init__(
37
37
if isinstance (spark_job_configuration , JobConfiguration ):
38
38
self ._spark_job_configuration = spark_job_configuration
39
39
elif isinstance (spark_job_configuration , dict ):
40
- self ._spark_job_configuration = JobConfiguration (** spark_job_configuration if spark_job_configuration else {}). to_dict ()
40
+ self ._spark_job_configuration = JobConfiguration (** spark_job_configuration if spark_job_configuration else {})
41
41
42
42
@property
43
43
def query (self ):
You can’t perform that action at this time.
0 commit comments