Commit ecf3380 1 parent f86a52c commit ecf3380 Copy full SHA for ecf3380
File tree 4 files changed +3
-12
lines changed
4 files changed +3
-12
lines changed Original file line number Diff line number Diff line change @@ -144,14 +144,13 @@ def collection_pipeline_makerules_cmd(
144
144
incremental_loading_override ,
145
145
state_path ,
146
146
):
147
- print ("state path" , state_path )
148
147
return collection_pipeline_makerules (
149
148
collection_dir ,
150
149
specification_dir ,
151
150
pipeline_dir ,
152
151
resource_dir ,
153
152
incremental_loading_override ,
154
- state_path ,
153
+ state_path = state_path ,
155
154
)
156
155
157
156
Original file line number Diff line number Diff line change @@ -426,7 +426,7 @@ def pipeline_makerules(
426
426
pipeline_dir ,
427
427
resource_dir ,
428
428
incremental_loading_override ,
429
- state_path = None ,
429
+ state_path = state_path ,
430
430
)
431
431
432
432
def dataset_resource_map (self ):
Original file line number Diff line number Diff line change @@ -118,7 +118,7 @@ def collection_pipeline_makerules(
118
118
pipeline_dir ,
119
119
resource_dir ,
120
120
incremental_loading_override ,
121
- state_path = None ,
121
+ state_path = state_path ,
122
122
)
123
123
124
124
Original file line number Diff line number Diff line change @@ -74,14 +74,6 @@ def pipeline_makerules(
74
74
state_path = None ,
75
75
):
76
76
dataset_resource = collection .dataset_resource_map ()
77
- print (
78
- "inputs:" ,
79
- specification_dir ,
80
- pipeline_dir ,
81
- resource_dir ,
82
- incremental_loading_override ,
83
- state_path ,
84
- )
85
77
process = get_processing_option (
86
78
collection ,
87
79
specification_dir ,
You can’t perform that action at this time.
0 commit comments