File tree Expand file tree Collapse file tree 2 files changed +6
-6
lines changed
ext/scheduler/airflow/dag Expand file tree Collapse file tree 2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -157,7 +157,7 @@ init_container = k8s.V1Container(
157
157
depends_on_past={{ if .JobDetails.Schedule.DependsOnPast }}True{{- else -}}False{{- end -}},
158
158
in_cluster=True,
159
159
is_delete_operator_pod=True,
160
- do_xcom_push=True ,
160
+ do_xcom_push=False ,
161
161
env_vars=executor_env_vars,
162
162
{{- if gt .SLAMissDuration 0 }}
163
163
sla=timedelta(seconds={{ .SLAMissDuration }}),
@@ -204,7 +204,7 @@ hook_{{$hookName}} = SuperKubernetesPodOperator(
204
204
dag=dag,
205
205
in_cluster=True,
206
206
is_delete_operator_pod=True,
207
- do_xcom_push=True ,
207
+ do_xcom_push=False ,
208
208
env_vars=executor_env_vars,
209
209
{{- if $t.IsFailHook }}
210
210
trigger_rule="one_failed",
Original file line number Diff line number Diff line change 126
126
depends_on_past = False ,
127
127
in_cluster = True ,
128
128
is_delete_operator_pod = True ,
129
- do_xcom_push = True ,
129
+ do_xcom_push = False ,
130
130
env_vars = executor_env_vars ,
131
131
sla = timedelta (seconds = 7200 ),
132
132
resources = resources ,
167
167
dag = dag ,
168
168
in_cluster = True ,
169
169
is_delete_operator_pod = True ,
170
- do_xcom_push = True ,
170
+ do_xcom_push = False ,
171
171
env_vars = executor_env_vars ,
172
172
resources = resources ,
173
173
reattach_on_restart = True ,
205
205
dag = dag ,
206
206
in_cluster = True ,
207
207
is_delete_operator_pod = True ,
208
- do_xcom_push = True ,
208
+ do_xcom_push = False ,
209
209
env_vars = executor_env_vars ,
210
210
resources = resources ,
211
211
reattach_on_restart = True ,
243
243
dag = dag ,
244
244
in_cluster = True ,
245
245
is_delete_operator_pod = True ,
246
- do_xcom_push = True ,
246
+ do_xcom_push = False ,
247
247
env_vars = executor_env_vars ,
248
248
trigger_rule = "one_failed" ,
249
249
resources = resources ,
You can’t perform that action at this time.
0 commit comments