initial stage

2024-08-01 10:57:08 +02:00 · 2024-08-01 10:57:08 +02:00 · 9581a86313
parent f22f89b54c
commit 9581a86313
1 changed files with 1 additions and 1 deletions
--- a/airflow/dags/test_dag.py
+++ b/airflow/dags/test_dag.py
@ -74,7 +74,7 @@ def import_s3_openaire_dump():
            kwargs = get_current_context()
            print(files)

-        parallel_load.expand(compute_batches())
+        parallel_load.expand(files=compute_batches())

    @task
    def merge_curation_db(**kwargs):