From 5b5ffc8a67fae3375edf40a5dbe6704678bc254e Mon Sep 17 00:00:00 2001
From: Meelap Shah <meelapshah@gmail.com>
Date: Thu, 6 Apr 2017 12:54:24 -0400
Subject: [PATCH] removeTasksForSlave: fix logic to identify tasks running on
 slave

---
 .../org/apache/mesos/chronos/scheduler/jobs/TaskManager.scala   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)
     }