pendulum

stellar · Apr 17, 2024 · e4346c3 · e4346c3
1 parent be506fb
commit e4346c3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py
@@ -1,4 +1,5 @@
 import json
+import pendulum
 from datetime import datetime, timedelta
 
 from airflow import DAG
@@ -9,7 +10,7 @@
 
 
 def compare_transforms_and_bq_rows():
-    yesterday = "{{ts(execution_date - macros.timedelta(days=1))}}"
+    yesterday = pendulum.datetime(2024, 4, 16, tz="UTC")
     # Get all the execution dates for the current date
     execution_dates = DagRun.find(
         dag_id="history_archive_without_captive_core", execution_date=yesterday