-
Notifications
You must be signed in to change notification settings - Fork 134
/
jobstates.go
92 lines (81 loc) · 2.73 KB
/
jobstates.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
package lookout
import "github.com/armadaproject/armada/internal/common/util"
type JobState string
type JobRunState string
const (
JobQueued JobState = "QUEUED"
JobPending JobState = "PENDING"
JobRunning JobState = "RUNNING"
JobSucceeded JobState = "SUCCEEDED"
JobFailed JobState = "FAILED"
JobCancelled JobState = "CANCELLED"
JobPreempted JobState = "PREEMPTED"
JobLeased JobState = "LEASED"
JobQueuedOrdinal = 1
JobPendingOrdinal = 2
JobRunningOrdinal = 3
JobSucceededOrdinal = 4
JobFailedOrdinal = 5
JobCancelledOrdinal = 6
JobPreemptedOrdinal = 7
JobLeasedOrdinal = 8
JobRunLeased JobRunState = "RUN_LEASED"
JobRunPending JobRunState = "RUN_PENDING"
JobRunRunning JobRunState = "RUN_RUNNING"
JobRunSucceeded JobRunState = "RUN_SUCCEEDED"
JobRunFailed JobRunState = "RUN_FAILED"
JobRunTerminated JobRunState = "RUN_TERMINATED"
JobRunPreempted JobRunState = "RUN_PREEMPTED"
JobRunUnableToSchedule JobRunState = "RUN_UNABLE_TO_SCHEDULE"
JobRunLeaseReturned JobRunState = "RUN_LEASE_RETURNED"
JobRunLeaseExpired JobRunState = "RUN_LEASE_EXPIRED"
JobRunMaxRunsExceeded JobRunState = "RUN_MAX_RUNS_EXCEEDED"
JobRunPendingOrdinal = 1
JobRunRunningOrdinal = 2
JobRunSucceededOrdinal = 3
JobRunFailedOrdinal = 4
JobRunTerminatedOrdinal = 5
JobRunPreemptedOrdinal = 6
JobRunUnableToScheduleOrdinal = 7
JobRunLeaseReturnedOrdinal = 8
JobRunLeaseExpiredOrdinal = 9
JobRunMaxRunsExceededOrdinal = 10
JobRunLeasedOrdinal = 11
)
var (
// JobStates is an ordered list of states
JobStates = []JobState{
JobQueued,
JobLeased,
JobPending,
JobRunning,
JobSucceeded,
JobFailed,
JobCancelled,
JobPreempted,
}
JobStateMap = map[int]JobState{
JobLeasedOrdinal: JobLeased,
JobQueuedOrdinal: JobQueued,
JobPendingOrdinal: JobPending,
JobRunningOrdinal: JobRunning,
JobSucceededOrdinal: JobSucceeded,
JobFailedOrdinal: JobFailed,
JobCancelledOrdinal: JobCancelled,
JobPreemptedOrdinal: JobPreempted,
}
JobStateOrdinalMap = util.InverseMap(JobStateMap)
JobRunStateMap = map[int]JobRunState{
JobRunLeasedOrdinal: JobRunLeased,
JobRunPendingOrdinal: JobRunPending,
JobRunRunningOrdinal: JobRunRunning,
JobRunSucceededOrdinal: JobRunSucceeded,
JobRunFailedOrdinal: JobRunFailed,
JobRunTerminatedOrdinal: JobRunTerminated,
JobRunPreemptedOrdinal: JobRunPreempted,
JobRunUnableToScheduleOrdinal: JobRunUnableToSchedule,
JobRunLeaseReturnedOrdinal: JobRunLeaseReturned,
JobRunLeaseExpiredOrdinal: JobRunLeaseExpired,
JobRunMaxRunsExceededOrdinal: JobRunMaxRunsExceeded,
}
)