From 2cb40d2276addc9c7da64066b59144dfa5978cc8 Mon Sep 17 00:00:00 2001 From: Giambattista Bloisi Date: Tue, 12 Mar 2024 12:56:24 +0100 Subject: [PATCH] simple test DAG --- airflow/dags/skg_if_pipeline.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/airflow/dags/skg_if_pipeline.py b/airflow/dags/skg_if_pipeline.py index f6ad045..c9caa0c 100644 --- a/airflow/dags/skg_if_pipeline.py +++ b/airflow/dags/skg_if_pipeline.py @@ -102,12 +102,12 @@ def skg_if_pipeline(): verify=False) unzip_to_s3("dump.zip", S3_BUCKET_NAME) - bulk_load("datasource") - bulk_load("grant") - bulk_load("organization") + bulk_load("datasources") + bulk_load("grants") + bulk_load("organizations") bulk_load("persons") - bulk_load("research_product") - bulk_load("topic") + bulk_load("products") + bulk_load("topics") bulk_load("venues")