yesterday datetime

stellar · Apr 17, 2024 · a96ade1 · a96ade1
1 parent 66ad112
commit a96ade1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py
@@ -1,6 +1,6 @@
 from datetime import datetime, timedelta
 
-import pendulum
+#import pendulum
 from airflow import DAG, settings
 from airflow.models import DagBag, DagRun, TaskInstance, Variable
 from airflow.operators.python_operator import PythonOperator
@@ -11,7 +11,7 @@
 
 def compare_transforms_and_bq_rows():
     # Try yesterday_ds again
-    yesterday = "{{ yesterday_ds }}"
+    yesterday = datetime.now() - timedelta(days=1)
     # Get all the execution dates for the current date
     # Get the session from the settings
     session = settings.Session()