task结果处理函数,用于进行数据传递发送与中间数据上报 :param result: :return:
(self, result)
| 126 | raise SourceMgrError("task类型错误:%s" % str(self.task_type)) |
| 127 | |
| 128 | def done_task(self, result): |
| 129 | """ |
| 130 | task结果处理函数,用于进行数据传递发送与中间数据上报 |
| 131 | :param result: |
| 132 | :return: |
| 133 | """ |
| 134 | if self.task_type is CompileTask: |
| 135 | return self._done_compile(result) |
| 136 | elif self.task_type is AnalyzeTask: |
| 137 | return self._done_analyze(result) |
| 138 | elif self.task_type is DataHandleTask: |
| 139 | return self._done_result(result) |
| 140 | raise SourceMgrError("task类型错误:%s" % str(self.task_type)) |
| 141 | |
| 142 | def _pre_compile(self): |
| 143 | """ |
no test coverage detected