From 954b4ec32b02f4835b7cb89b9e5dcfea59cfcdcd Mon Sep 17 00:00:00 2001
From: Miroslav Stampar <miroslav.stampar@gmail.com>
Date: Wed, 27 Jan 2016 21:25:34 +0100
Subject: [PATCH] Fix for #1676

---
 lib/utils/api.py | 19 +++++++++----------
 1 file changed, 9 insertions(+), 10 deletions(-)

diff --git a/lib/utils/api.py b/lib/utils/api.py
index 9513f31f4..b22fa6e09 100644
--- a/lib/utils/api.py
+++ b/lib/utils/api.py
@@ -177,10 +177,10 @@ class Task(object):
 
     def engine_kill(self):
         if self.process:
-            self.process.kill()
-            return self.process.wait()
-        else:
-            return None
+            try:
+                self.process.kill()
+            except:
+                pass
 
     def engine_get_id(self):
         if self.process:
@@ -391,12 +391,11 @@ def task_flush(taskid):
     """
     Flush task spool (delete all tasks)
     """
-    if is_admin(taskid):
-        DataStore.tasks = dict()
-    else:
-        for key in list(DataStore.tasks):
-            if DataStore.tasks[key].remote_addr == request.remote_addr:
-                del DataStore.tasks[key]
+
+    for key in list(DataStore.tasks):
+        if is_admin(taskid) or DataStore.tasks[key].remote_addr == request.remote_addr:
+            DataStore.tasks[key].engine_kill()
+            del DataStore.tasks[key]
 
     logger.debug("[%s] Flushed task pool (%s)" % (taskid, "admin" if is_admin(taskid) else request.remote_addr))
     return jsonize({"success": True})