From 4ffa1b2618fb7d79ced9a34223567f1c5b50ff40 Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Fri, 19 Apr 2024 13:28:20 -0300 Subject: [PATCH] working --- dags/stellar_etl_airflow/test_sources.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 8a5cea11..a368cbfa 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -29,7 +29,7 @@ def get_from_combinedExport(**context): execution_dates = ( session.query(DagRun) .filter( - DagRun.dag_id == "history_archive_without_captive_core", + DagRun.dag_id == "history_archive_with_captive_core_combined_export", DagRun.execution_date >= yesterday.start_of("day"), DagRun.execution_date < yesterday.add(days=1).start_of("day"), DagRun.state == State.SUCCESS, @@ -39,9 +39,6 @@ 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"