Method __retry_checkout

client/task/sourcemgr.py:367–406

拉取代码到一个新的目录;如果失败,删除代码目录再重新拉取 :param scm_mgr: :return:

(self, scm_mgr)

            self.__retry_checkout(sm)

    def __retry_checkout(self, scm_mgr):
        """
        拉取代码到一个新的目录;如果失败,删除代码目录再重新拉取
        :param scm_mgr:
        :return:
        """
        # 上报进度
        SourceReporter(self.task_type, self.params).checkout_report()

        interval = 30  # 重试间隔(单位: 秒)
        retry_max = 2  # 重试次数
        retry_cnt = 0  # 重试计数
        while True:
            try:
                scm_mgr.get_scm_client().checkout(
                    revision=self.params["scm_revision"],
                    enable_submodules=self.enable_submodules,
                    enable_lfs=self.enable_lfs
                )
                if retry_cnt != 0:
                    logger.info("checkout succeed after %d retries.", retry_cnt)
                return
            except ScmCommandError as err:
                logger.warning("checkout fails on error: %s" % str(err))
                if retry_cnt < retry_max:
                    # 先清理代码目录
                    if self.params["scm_type"] in ["git", "tgit"]:
                        PathMgr().rmpath(self.params["source_dir"])
                    elif self.params["scm_type"] == "svn":
                        scm_mgr.get_scm_client().cleanup()

                    # 准备重试
                    retry_cnt += 1
                    interval = interval * retry_cnt  # 重试间隔递增,第一次间隔30s，第二次60s
                    logger.warning("retry after %s seconds..." % interval)
                    time.sleep(interval)
                    continue
                else:
                    logger.warning("checkout still fails after %s retries!" % retry_cnt)
                    raise


class SourceMiddleInfo(object):