终止任务后端

DAPlatform/views/task.py

@@ -270,3 +270,27 @@ def finish_task():
         'data': ret.data
     }
     return json.dumps(res)
+
+
+# 终止任务
+@task.route("/terminateTask", methods=["Post"])
+def terminate_task():
+    userId = int(request.args['userId'])
+    taskId = request.args['taskId']
+    task = Task.find_task_by_id(taskId)
+    if task.publish_id == userId:
+        Task.set_state(taskId, 'terminate')
+
+        res = {
+            'code': 1,
+            'message': "terminate success",
+            'data': {}
+        }
+        return json.dumps(res)
+    else:
+        res = {
+            'code': 0,
+            'message': "terminate failed",
+            'data': {}
+        }
+        return json.dumps(res)