diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index a368cbfa..f0fea5c3 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -39,6 +39,8 @@ def get_from_combinedExport(**context): gcs_hook = GCSHook(google_cloud_storage_conn_id="google_cloud_storage_default") + print(f"how many runs: {len(execution_dates)}") + for dag_run in execution_dates: execution_date_str = dag_run.execution_date.strftime( "%Y-%m-%d %H:%M:%S%z"