Movatterモバイル変換

Skip to content

raystack/optimusPublic

NotificationsYou must be signed in to change notification settings
Fork154
Star756

Commitad3c691

irainia

committed

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

1 parent82b0244 commitad3c691Copy full SHA for ad3c691

File tree

2 files changed

+6

-6

lines changed

ext/scheduler/airflow/dag
- dag.py.tmpl
- expected_dag.py

2 files changed

+6

-6

lines changed

`‎ext/scheduler/airflow/dag/dag.py.tmpl‎`

Lines changed: 2 additions & 2 deletions

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",`

`‎ext/scheduler/airflow/dag/expected_dag.py‎`

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,7 @@`
`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,7 +167,7 @@`
`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,7 +205,7 @@`
`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,7 +243,7 @@`
`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,`

0 commit comments

Comments

(0)

[8]ページ先頭

©2009-2025 Movatter.jp