print(dag_run.execution_date)

stellar · Apr 19, 2024 · 4a43503 · 4a43503
1 parent 14a108b
commit 4a43503
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py
@@ -39,6 +39,9 @@ def get_from_combinedExport(**context):
 
     gcs_hook = GCSHook(google_cloud_storage_conn_id="google_cloud_storage_default")
 
+    for dag_run in execution_dates:
+        print(dag_run.execution_date)
+
     for dag_run in execution_dates:
         execution_date_str = dag_run.execution_date.strftime(
             "%Y-%m-%d %H:%M:%S%z"