plan.py 文件源码

def __init__(self, generator):
        """
        Parameters
        ----------
        generator : function
            the function (generator) to be used

        """
        super(ExecutionPlan, self).__init__()

        if not isinstance(generator, types.GeneratorType):
            generator = generator()

        assert isinstance(generator, types.GeneratorType)

        self._generator = generator
        self._running = True
        self._finish_conditions = []