Class SourceReporter

client/task/sourcemgr.py:42–96

代码相关的进度上报

class SourceReporter(object):
    """
    代码相关的进度上报
    """
    def __init__(self, task_type, task_params):
        self.task_type = task_type
        self.params = task_params

    def cache_report(self):
        """
        进度上报：应用缓存代码
        :return:
        """
        if self.task_type is CompileTask:
            Reporter(self.params).update_task_progress(InfoType.CompileCacheSource)
        elif self.task_type is AnalyzeTask:
            Reporter(self.params).update_task_progress(InfoType.AnalyzeCacheSource)
        elif self.task_type is DataHandleTask:
            Reporter(self.params).update_task_progress(InfoType.DataHandleCacheSource)

    def update_report(self):
        """
        进度上报：更新代码
        :return:
        """
        if self.task_type is CompileTask:
            Reporter(self.params).update_task_progress(InfoType.CompileSourceUpdate)
        elif self.task_type is AnalyzeTask:
            Reporter(self.params).update_task_progress(InfoType.AnalyzeSourceUpdate)
        elif self.task_type is DataHandleTask:
            Reporter(self.params).update_task_progress(InfoType.DataHandleSourceUpdate)

    def update_retry_report(self):
        """
        进度上报：更新代码失败后,重新拉取代码
        :return:
        """
        if self.task_type is CompileTask:
            Reporter(self.params).update_task_progress(InfoType.CompileSourceReLoad)
        elif self.task_type is AnalyzeTask:
            Reporter(self.params).update_task_progress(InfoType.AnalyzeSourceReLoad)
        elif self.task_type is DataHandleTask:
            Reporter(self.params).update_task_progress(InfoType.DataHandleSourceReLoad)

    def checkout_report(self):
        """
        进度上报：拉取代码
        :return:
        """
        if self.task_type is CompileTask:
            Reporter(self.params).update_task_progress(InfoType.CompileSourceCheckout)
        elif self.task_type is AnalyzeTask:
            Reporter(self.params).update_task_progress(InfoType.AnalyzeSourceCheckout)
        elif self.task_type is DataHandleTask:
            Reporter(self.params).update_task_progress(InfoType.DataHandleSourceCheckout)


class SourceManager(object):