Skip to content

Commit

Permalink
u007d
Browse files Browse the repository at this point in the history
  • Loading branch information
laysabit committed Apr 12, 2024
1 parent dfac662 commit 28417b9
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 @@ -212,11 +212,11 @@ def build_export_task(
if command == "export_ledger_entry_changes" or command == "export_all_history":
arguments = f"""{etl_cmd_string} && echo "{{\\"output\\": \\"{output_file}\\"}}" >> /airflow/xcom/return.json"""
else:
char = '}'
char = "}"
arguments = """
{0} 2>> stderr.out && cat stderr.out && echo "{{\\"output\\": \\"{1}\\",
\\"failed_transforms\\": `grep failed_transforms stderr.out | cut -d\\",\\" -f2 | cut -d\\":\\" -f2`,
\\"successful_transforms\\": `grep successful_transforms stderr.out | , cut -d\\",\\" -f3 | cut -d\\":\\" -f2 | tr -d \\"{2}\\"`}}" >> /airflow/xcom/return.json
\\"successful_transforms\\": `grep successful_transforms stderr.out | cut -d\\",\\" -f3 | cut -d\\":\\" -f2 | tr -d \\"\u007d\\"`}}" >> /airflow/xcom/return.json
""".format(
etl_cmd_string, output_file, char
)
Expand Down

0 comments on commit 28417b9

Please sign in to comment.