diff --git a/dags/stellar_etl_airflow/build_export_task.py b/dags/stellar_etl_airflow/build_export_task.py index 0fec56d9..9077f432 100644 --- a/dags/stellar_etl_airflow/build_export_task.py +++ b/dags/stellar_etl_airflow/build_export_task.py @@ -214,7 +214,7 @@ def build_export_task( else: arguments = """ {0} 2>> stderr.out && cat stderr.out && echo "{{\\"output\\": \\"{1}\\", - \\"attempted_transforms\\": `grep attempted_transforms stderr.out | cut -d\\",\\" -f2 | cut -d\\":\\" -f2`, + \\"attempted_transforms\\": `grep attempted_transforms stderr.out | cut -d\\",\\" -f1 | 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