in core/__init__.py [0:0]
def __call__(self, func):
from functools import partial
from .standalone import run
if self.name in self.__pipes__:
module = self.__pipes__[self.name].func.__module__
raise ConfigError(f"pipe '{self.name}' is already defined in module '{module}'")
self.__pipes__[self.name] = self
self.func = func
return partial(run, self)