fix: change xcom push to false as default to unblock deployment for now

raystack · Feb 24, 2023 · ad3c691 · ad3c691
1 parent 82b0244
commit ad3c691
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/ext/scheduler/airflow/dag/dag.py.tmpl b/ext/scheduler/airflow/dag/dag.py.tmpl
@@ -157,7 +157,7 @@ init_container = k8s.V1Container(
     depends_on_past={{ if .JobDetails.Schedule.DependsOnPast }}True{{- else -}}False{{- end -}},
     in_cluster=True,
     is_delete_operator_pod=True,
-    do_xcom_push=True,
+    do_xcom_push=False,
     env_vars=executor_env_vars,
     {{- if gt .SLAMissDuration 0 }}
     sla=timedelta(seconds={{ .SLAMissDuration }}),
@@ -204,7 +204,7 @@ hook_{{$hookName}} = SuperKubernetesPodOperator(
     dag=dag,
     in_cluster=True,
     is_delete_operator_pod=True,
-    do_xcom_push=True,
+    do_xcom_push=False,
     env_vars=executor_env_vars,
     {{- if $t.IsFailHook }}
     trigger_rule="one_failed",

diff --git a/ext/scheduler/airflow/dag/expected_dag.py b/ext/scheduler/airflow/dag/expected_dag.py
@@ -126,7 +126,7 @@
     depends_on_past=False,
     in_cluster=True,
     is_delete_operator_pod=True,
-    do_xcom_push=True,
+    do_xcom_push=False,
     env_vars=executor_env_vars,
     sla=timedelta(seconds=7200),
     resources=resources,
@@ -167,7 +167,7 @@
     dag=dag,
     in_cluster=True,
     is_delete_operator_pod=True,
-    do_xcom_push=True,
+    do_xcom_push=False,
     env_vars=executor_env_vars,
     resources=resources,
     reattach_on_restart=True,
@@ -205,7 +205,7 @@
     dag=dag,
     in_cluster=True,
     is_delete_operator_pod=True,
-    do_xcom_push=True,
+    do_xcom_push=False,
     env_vars=executor_env_vars,
     resources=resources,
     reattach_on_restart=True,
@@ -243,7 +243,7 @@
     dag=dag,
     in_cluster=True,
     is_delete_operator_pod=True,
-    do_xcom_push=True,
+    do_xcom_push=False,
     env_vars=executor_env_vars,
     trigger_rule="one_failed",
     resources=resources,