workflow_template.py 文件源码

def do_caller_job(self, line):
        """
        ??????????Job??
        :param line ????????? [?????]
        """
        cmd_args = re.split(r"\s+", line)
        unit_name = cmd_args[0].strip()

        if unit_name in self.units:
            print colored(u"???? '{}' ????".format(unit_name), "red")
            return

        if len(cmd_args) >= 2:
            func_name = cmd_args[1].strip()
        else:
            func_name = None

        job_tpl = CallerBasedJobTemplate(unit_name, func_name)
        self.units.append(job_tpl)