From 9581a863134bef8f4e2fa0b32d3c91c807642596 Mon Sep 17 00:00:00 2001
From: Giambattista Bloisi <giambattista.bloisi@openaire.eu>
Date: Thu, 1 Aug 2024 10:57:08 +0200
Subject: [PATCH] initial stage

---
 airflow/dags/test_dag.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/dags/test_dag.py b/airflow/dags/test_dag.py
index 9f55563..601200e 100644
--- 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):