diff --git a/airflow/dags/populate_opensearch.py b/airflow/dags/populate_opensearch.py
index 1ed3946..1c8a123 100644
--- a/airflow/dags/populate_opensearch.py
+++ b/airflow/dags/populate_opensearch.py
@@ -80,6 +80,6 @@ with DAG(
     start_date=datetime(2021, 1, 1),
     catchup=False,
 ) as dag:
-    bulk_load_data = bulk_load("")
+    bulk_load_data = bulk_load()
     chain(bulk_load_data)