From 75c4c6e0d4c5c945a08ff00089bdf90e2c941fb9 Mon Sep 17 00:00:00 2001 From: Amisha Singla Date: Fri, 13 Dec 2024 16:07:46 -0600 Subject: [PATCH] debug --- dags/stellar_etl_airflow/build_internal_export_task.py | 1 + 1 file changed, 1 insertion(+) diff --git a/dags/stellar_etl_airflow/build_internal_export_task.py b/dags/stellar_etl_airflow/build_internal_export_task.py index f22c104e..2c4d0ea2 100644 --- a/dags/stellar_etl_airflow/build_internal_export_task.py +++ b/dags/stellar_etl_airflow/build_internal_export_task.py @@ -74,6 +74,7 @@ def build_export_task( f"'batch_id={batch_id},batch_run_date={batch_date},batch_insert_ts={batch_insert_ts}'", ] etl_cmd_string = " ".join(cmd_args) + output_filepath = "dag-exported/scheduled__2024-12-12T00:20:00+00:00/export_retool_data_exported_entity.txt" arguments = f""" {command} {etl_cmd_string} 1>> stdout.out 2>> stderr.out && cat stdout.out && cat stderr.out && echo "{{\\"output\\": \\"{output_filepath}\\"}}" >> /airflow/xcom/return.json""" return KubernetesPodOperator(