Method run

dataflow/wrapper/batch_wrapper.py:13–18

这里写一份通用的 run 文档也可以， 不写的话会被下面动态拷贝原 operator.run 的 __doc__。

(self, *args: P.args, **kwargs: P.kwargs)

class HasRun(Protocol[P, R]):
    def run(self, *args: P.args, **kwargs: P.kwargs) -> R:
        """
        这里写一份通用的 run 文档也可以，
        不写的话会被下面动态拷贝原 operator.run 的 __doc__。
        """
        ...

class BatchWrapper(Generic[P, R]):
    """