From a96ade1195861a4564bdd39d5cc92227dce65898 Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Wed, 17 Apr 2024 17:41:04 -0300 Subject: [PATCH] yesterday datetime --- dags/stellar_etl_airflow/test_sources.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 9d511197..6d1af92e 100644 --- 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()