Skip to content

Commit

Permalink
-f3
Browse files Browse the repository at this point in the history
  • Loading branch information
laysabit committed Apr 12, 2024
1 parent fd2d2bd commit be6b53f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dags/stellar_etl_airflow/build_export_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -213,8 +213,8 @@ def build_export_task(
arguments = f"""{etl_cmd_string} && echo "{{\\"output\\": \\"{output_file}\\"}}" >> /airflow/xcom/return.json"""
else:
arguments = """
{0} 2>> stderr.out && cat stderr.out && echo "{{\\"output\\": \\"{1}\\",
\\"attempted_transforms\\": `grep attempted_transforms stderr.out | cut -d\\",\\" -f1 | cut -d\\":\\" -f2`,
{0} 2>> stderr.out && echo "{{\\"output\\": \\"{1}\\",
\\"attempted_transforms\\": `grep attempted_transforms stderr.out | cut -d\\",\\" -f3 | cut -d\\":\\" -f2`,
\\"failed_transforms\\": `grep failed_transforms stderr.out | cut -d\\",\\" -f2 | cut -d\\":\\" -f2`}}" >> /airflow/xcom/return.json
""".format(
etl_cmd_string, output_file
Expand Down

0 comments on commit be6b53f

Please sign in to comment.