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")