From 49aa04cb98aa034e6308403392e7b0a0076c6c67 Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Thu, 11 Apr 2024 17:17:33 -0300 Subject: [PATCH] cut -d\\",\\" -f3 --- dags/stellar_etl_airflow/build_export_task.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/stellar_etl_airflow/build_export_task.py b/dags/stellar_etl_airflow/build_export_task.py index bd4fa3c5..cae51f64 100644 --- a/dags/stellar_etl_airflow/build_export_task.py +++ b/dags/stellar_etl_airflow/build_export_task.py @@ -215,7 +215,7 @@ def build_export_task( 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 \"}}\" ` }}" >> /airflow/xcom/return.json + \\"successful_transforms\\: `grep successful_transforms stderr.out | cut -d\\",\\" -f3 | cut -d\\":\\" -f2 | tr -d \"}}\" ` }}" >> /airflow/xcom/return.json """.format( etl_cmd_string, output_file )