管理当前在执行的任务,如果任务结束,上传分析结果,并从self._running_task列表中删除
(self)
| 57 | self._origin_os_env = dict(os.environ) |
| 58 | |
| 59 | def _handle_exist_task(self): |
| 60 | """管理当前在执行的任务,如果任务结束,上传分析结果,并从self._running_task列表中删除 |
| 61 | """ |
| 62 | for task in self._running_task[:]: |
| 63 | if task.done: |
| 64 | LogPrinter.info('task %s with id %d is done', task.task_name, task.task_id) |
| 65 | # 从任务队列中删除 |
| 66 | self._running_task.remove(task) |
| 67 | # 上传结果到server |
| 68 | self._send_result(task) |
| 69 | # # 分析任务完成后,按照磁盘空间和创建时间清理数据 |
| 70 | # LogPrinter.info("clean data directory ...") |
| 71 | # SourceManager.del_old_file() |
| 72 | |
| 73 | def _terminate_task(self, task_id): |
| 74 | """kill task""" |
no test coverage detected