We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 811de70 commit 51b0c5cCopy full SHA for 51b0c5c
src/pyff/pipes.py
@@ -24,6 +24,15 @@
24
25
26
def pipe(*args, **kwargs) -> Callable:
27
+ """
28
+ A decorator that registers a function as a pipeline in pyFF. Functions decorated *should* have the
29
+ following prototype:
30
+
31
+ @pipe
32
+ def foo(req: Plumbing.Request, *opts)
33
+ pass
34
35
36
def pipe_decorator(f: Callable) -> Callable:
37
if 'name' in kwargs: # called with the name argument @pipe(name=...) or as @pipe()
38
f_name = kwargs.get('name', f.__name__)
0 commit comments