__init__.py 文件源码

def build(self):

        # ????????????????options????
        if isinstance(self._units, types.FunctionType):
            self._units = self._units(self._options)

        workflow = self._clazz(
            self._units,
            config=self._config,
            plugin_mgr=self._plugin_mgr,
            context_factory=self._context_factory,
            logger=self._logger
        )
        if self._listeners:
            for listener in self._listeners:
                workflow.add_listener(listener)

        return workflow