Skip to content

Commit 8cb553f

Browse files
committed
Call ODC.Stop in case that we go to ERROR
This commit needs a corresponding change in AliECS which adds a check for "RUNNING" state in Odc.Stop before actually calling, so it is not done when inappropriate. Fixes OCTRL-1036
1 parent bf6a04d commit 8cb553f

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

workflows/readout-dataflow.yaml

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1294,6 +1294,7 @@ defaults:
12941294
odc_configure_timeout: "60s"
12951295
odc_start_timeout: "60s"
12961296
odc_stop_timeout: "60s"
1297+
odc_goerror_timeout: "60s"
12971298
odc_reset_timeout: "60s"
12981299
odc_partitionterminate_timeout: "60s"
12991300
odc_cleanup_timeout: "60s"
@@ -1928,6 +1929,13 @@ roles:
19281929
await: after_STOP_ACTIVITY-50
19291930
timeout: "{{ odc_stop_timeout }}"
19301931
critical: true
1932+
- name: go-error
1933+
call:
1934+
func: odc.Stop()
1935+
trigger: before_GO_ERROR
1936+
await: after_GO_ERROR-1
1937+
timeout: "{{ odc_goerror_timeout }}"
1938+
critical: true
19311939
- name: reset
19321940
call:
19331941
func: odc.Reset()

0 commit comments

Comments
 (0)