diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index d1a072e4..7807ed3b 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -20,8 +20,8 @@ def compare_transforms_and_bq_rows(): session.query(DagRun) .filter( DagRun.dag_id == "history_archive_without_captive_core", - DagRun.execution_date >= yesterday.start_of('day'), - DagRun.execution_date < yesterday.add(days=1).start_of('day'), + DagRun.execution_date >= yesterday.start_of("day"), + DagRun.execution_date < yesterday.add(days=1).start_of("day"), DagRun.state == State.SUCCESS, ) .all()