diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 83540aee..8a5cea11 100644 --- 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"