step.py 文件源码

def __init__(self, ev, step, progname, repeat=[1,], iter_triggers=(), end_triggers=(),):
        module_logger.debug("[ step %s ] Container initialization\n    iter_triggers: %s\n    end_triggers: %s\n    repeat: %s" % (progname, iter_triggers, end_triggers, repeat) )
        self.ev=ev
        self.progname=progname
        self.starters=iter_triggers
        self.enders=end_triggers
        if isinstance(repeat, AbcSequence):
            repeat=IterGen(repeat)
        self.repeat=repeat
        self.loop_index=0
        self.initiating_sequence=None
        self.step=step
        self.max_concurrent=self.step.config['max_concurrent']
        self.triggers=None