try

stellar · Apr 12, 2024 · 43dd3e8 · 43dd3e8
1 parent 131e314
commit 43dd3e8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/stellar_etl_airflow/build_export_task.py b/dags/stellar_etl_airflow/build_export_task.py
@@ -216,7 +216,7 @@ def build_export_task(
         arguments = """
                     \\"attempted_transforms\\": `grep attempted_transforms stderr.out | cut -d\\",\\" -f2 | rev | cut -d\\":\\" -f1 | rev`\\",
                     \\"failed_transforms\\": `grep failed_transforms stderr.out | cut -d\\",\\" -f2 | cut -d\\":\\" -f2`\\",
-                    \\"successful_transforms\\": `grep successful_transforms stderr.out | cut -d\\",\\" -f2 | cut -d\\":\\" -f1 | cut -d\\"{0}\\" -f1`}}" >> /airflow/xcom/return.json
+                    \\"successful_transforms\\": `grep successful_transforms stderr.out |  cut -d\\",\\" -f2 | cut -d\\":\\" -f1 | cut -d\\"{0}\\" -f1`}}" >> /airflow/xcom/return.json
                     """.format(char)
     return KubernetesPodOperator(
         service_account_name=Variable.get("k8s_service_account"),