Skip to content

Commit

Permalink
debug
Browse files Browse the repository at this point in the history
  • Loading branch information
amishas157 committed Dec 13, 2024
1 parent ab8be7a commit 75c4c6e
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions dags/stellar_etl_airflow/build_internal_export_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 75c4c6e

Please sign in to comment.