Commit b2c40ef 1 parent f326c4a commit b2c40ef Copy full SHA for b2c40ef
File tree 2 files changed +3
-4
lines changed
tests/e2e/pipeline_config
2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -359,7 +359,8 @@ def pipeline_run(
359
359
issue_log .save (os .path .join (issue_dir , resource + ".csv" ))
360
360
issue_log .save_parquet (os .path .join (output_log_dir , "issue/" ))
361
361
operational_issue_log .save (output_dir = operational_issue_dir )
362
- column_field_log .save (os .path .join (column_field_dir , resource + ".csv" ))
362
+ if column_field_dir :
363
+ column_field_log .save (os .path .join (column_field_dir , resource + ".csv" ))
363
364
dataset_resource_log .save (os .path .join (dataset_resource_dir , resource + ".csv" ))
364
365
converted_resource_log .save (os .path .join (converted_resource_dir , resource + ".csv" ))
365
366
# create converted parquet in the var directory
Original file line number Diff line number Diff line change @@ -348,13 +348,11 @@ def test_pipeline_run(test_dirs):
348
348
operational_issue_dir = operational_issue_dir ,
349
349
organisation_path = organisation_path ,
350
350
save_harmonised = False ,
351
- column_field_dir = pipeline_dir ,
352
351
dataset_resource_dir = dataset_resource_dir ,
353
352
converted_resource_dir = converted_resource_dir ,
354
- custom_temp_dir = None , # TBD: rename to "tmpdir"
355
353
endpoints = test_endpoints ,
356
354
organisations = [],
357
- entry_date = "" ,
355
+ entry_date = "2012-02-01 " ,
358
356
output_log_dir = output_log_dir ,
359
357
)
360
358
You can’t perform that action at this time.
0 commit comments