diff --git a/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/TaskManager.scala b/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/TaskManager.scala index 603ed8e89..fd2acde17 100644 --- a/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/TaskManager.scala +++ b/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/TaskManager.scala @@ -130,7 +130,7 @@ class TaskManager @Inject()( val jobs = runningTasks.map { case (jobName, tasks) => val remaining = tasks.filter { task => - slaveId == task.slaveId + slaveId != task.slaveId } (jobName, remaining) }