From 645d2c8cf24ab614416801fa05539da46807bd8f Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Wed, 17 Apr 2024 15:03:28 -0300 Subject: [PATCH] . --- dags/stellar_etl_airflow/test_sources.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 7807ed3b..35f8de3b 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -10,12 +10,13 @@ def compare_transforms_and_bq_rows(): - yesterday = pendulum.datetime(2024, 4, 16, tz="UTC") # Try yesterday_ds again + # Try yesterday_ds again + yesterday = pendulum.datetime(2024, 4, 16, tz="UTC") # Get all the execution dates for the current date # Get the session from the settings session = settings.Session() - # Get all the execution dates for the current date (yesterday) + # Get all the execution dates for the current date (yesterday) execution_dates = ( session.query(DagRun) .filter(