From 28417b909a884e61fc3c700429ab0f7f18e05b12 Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Thu, 11 Apr 2024 21:47:08 -0300 Subject: [PATCH] u007d --- dags/stellar_etl_airflow/build_export_task.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dags/stellar_etl_airflow/build_export_task.py b/dags/stellar_etl_airflow/build_export_task.py index 25b85dfc..cf1c96de 100644 --- a/dags/stellar_etl_airflow/build_export_task.py +++ b/dags/stellar_etl_airflow/build_export_task.py @@ -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 )