From ff6dbece82787ebf1d34ea80eeb69a81656014bd Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Fri, 19 Apr 2024 17:46:04 -0300 Subject: [PATCH] test --- dags/stellar_etl_airflow/test_sources.py | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 11a27f5f..317a75df 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -147,9 +147,10 @@ def get_from_combinedExport(**context): def get_from_without_captiveCore(**context): - execution_date = context["execution_date"] - yesterday = pendulum.instance(execution_date).subtract(days=1) - yesterday = datetime.combine(yesterday, time(), tzinfo=pytz.timezone("UTC")) + # execution_date = context["execution_date"] + # yesterday = pendulum.instance(execution_date).subtract(days=1) + # yesterday = datetime.combine(yesterday, time(), tzinfo=pytz.timezone("UTC")) + yesterday = pendulum.datetime(2024, 4, 16, tz="UTC") # Get the session from the settings session = settings.Session() @@ -226,9 +227,9 @@ def get_from_without_captiveCore(**context): dag=dag, ) -# compare2_task = PythonOperator( -# task_id="get_from_combinedExport", -# python_callable=get_from_combinedExport, -# provide_context=True, -# dag=dag, -# ) +compare2_task = PythonOperator( + task_id="get_from_combinedExport", + python_callable=get_from_combinedExport, + provide_context=True, + dag=dag, +)