giambattista.bloisi
/
lot1-kickoff
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

simple test DAG

This commit is contained in:
Giambattista Bloisi 2024-03-12 15:59:20 +01:00
parent f5ef2d3754
commit 815ce27e34
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
airflow/dags/skg_if_pipeline.py
View File

@ -104,13 +104,13 @@ def skg_if_pipeline():
chain(
unzip_to_s3.override(task_id=f"unzip_to_s3")("dump.zip", S3_BUCKET_NAME),
bulk_load.override(task_id=f"load_datasources")("datasources"),
[bulk_load.override(task_id=f"load_datasources")("datasources"),
bulk_load("grants"),
bulk_load("organizations"),
bulk_load("persons"),
bulk_load("products"),
bulk_load("topics"),
bulk_load("venues")
bulk_load("venues")]
)