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(