Skip to content

Commit

Permalink
Titus v3: handle missing titus health states
Browse files Browse the repository at this point in the history
  • Loading branch information
tomaslin committed Mar 26, 2018
1 parent be3fa83 commit 9d969b6
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -280,9 +280,9 @@ class TitusClusterCachingAgent implements CachingAgent, CustomScheduledAgent {
private Map<String, String> getTitusHealth(Job.TaskSummary task) {
TaskState taskState = task.state
HealthState healthState = HealthState.Unknown
if (taskState in [TaskState.STOPPED, TaskState.FAILED, TaskState.CRASHED, TaskState.FINISHED, TaskState.DEAD, TaskState.TERMINATING]) {
if (taskState in [TaskState.STOPPED, TaskState.FAILED, TaskState.CRASHED, TaskState.FINISHED, TaskState.DEAD, TaskState.TERMINATING, TaskState.KILLINITIATED, TaskState.DISCONNECTED]) {
healthState = HealthState.Down
} else if (taskState in [TaskState.STARTING, TaskState.DISPATCHED, TaskState.PENDING, TaskState.QUEUED]) {
} else if (taskState in [TaskState.STARTING, TaskState.DISPATCHED, TaskState.PENDING, TaskState.QUEUED, TaskState.ACCEPTED, TaskState.LAUNCHED, TaskState.STARTINITIATED]) {
healthState = HealthState.Starting
} else {
healthState = HealthState.Unknown
Expand Down

0 comments on commit 9d969b6

Please sign in to comment.