kill task
(self, task_id)
| 71 | # SourceManager.del_old_file() |
| 72 | |
| 73 | def _terminate_task(self, task_id): |
| 74 | """kill task""" |
| 75 | for task in self._running_task[:]: |
| 76 | if task and task.task_id == task_id: |
| 77 | task.terminate() |
| 78 | self._running_task.remove(task) |
| 79 | LogPrinter.info('terminate task %d by server', task_id) |
| 80 | |
| 81 | def _send_result(self, task): |
| 82 | """ |