Take ITERATING_ALWAYS into account when setting failed state in PlayIterator
Fixes #15963
This commit is contained in:
parent
1975a545bd
commit
4dc2bf4815
2 changed files with 8 additions and 3 deletions
|
@ -502,6 +502,8 @@ class PlayIterator:
|
||||||
elif state.fail_state != self.FAILED_NONE:
|
elif state.fail_state != self.FAILED_NONE:
|
||||||
if state.run_state == self.ITERATING_RESCUE and state.fail_state&self.FAILED_RESCUE == 0:
|
if state.run_state == self.ITERATING_RESCUE and state.fail_state&self.FAILED_RESCUE == 0:
|
||||||
return False
|
return False
|
||||||
|
elif state.run_state == self.ITERATING_ALWAYS and state.fail_state&self.FAILED_ALWAYS == 0:
|
||||||
|
return False
|
||||||
else:
|
else:
|
||||||
return True
|
return True
|
||||||
elif state.run_state == self.ITERATING_TASKS and self._check_failed_state(state.tasks_child_state):
|
elif state.run_state == self.ITERATING_TASKS and self._check_failed_state(state.tasks_child_state):
|
||||||
|
|
|
@ -70,9 +70,12 @@ class StrategyModule(StrategyBase):
|
||||||
if state_task and state_task[1]]
|
if state_task and state_task[1]]
|
||||||
|
|
||||||
if host_tasks_to_run:
|
if host_tasks_to_run:
|
||||||
lowest_cur_block = min(
|
try:
|
||||||
(s.cur_block for h, (s, t) in host_tasks_to_run
|
lowest_cur_block = min(
|
||||||
if s.run_state != PlayIterator.ITERATING_COMPLETE))
|
(s.cur_block for h, (s, t) in host_tasks_to_run
|
||||||
|
if s.run_state != PlayIterator.ITERATING_COMPLETE))
|
||||||
|
except ValueError:
|
||||||
|
lowest_cur_block = None
|
||||||
else:
|
else:
|
||||||
# empty host_tasks_to_run will just run till the end of the function
|
# empty host_tasks_to_run will just run till the end of the function
|
||||||
# without ever touching lowest_cur_block
|
# without ever touching lowest_cur_block
|
||||||
|
|
Loading…
Reference in a new issue