Skip to content

Commit d7258d3

Browse files
committed
Added CANCELLED
1 parent 86b8044 commit d7258d3

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

arc/job/pipe/pipe_state.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ class PipeRunState(str, Enum):
110110

111111
# Allowed transitions: maps each state to the set of states it may transition to.
112112
TASK_TRANSITIONS: Dict[TaskState, Tuple[TaskState, ...]] = {
113-
TaskState.PENDING: (TaskState.CLAIMED, TaskState.CANCELLED),
113+
TaskState.PENDING: (TaskState.CLAIMED, TaskState.CANCELLED, TaskState.FAILED_TERMINAL),
114114
TaskState.CLAIMED: (TaskState.RUNNING, TaskState.ORPHANED, TaskState.CANCELLED),
115115
TaskState.RUNNING: (TaskState.COMPLETED, TaskState.FAILED_RETRYABLE, TaskState.FAILED_ESS,
116116
TaskState.FAILED_TERMINAL, TaskState.ORPHANED, TaskState.CANCELLED),

0 commit comments

Comments
 (0)