pipe operator in python.

python_pipes.py

from functools import wraps

class Ror:
    def __init__(self, func, args, kwargs):
        self.func = func
        self.args = args
        self.kwargs = kwargs

    def __ror__(self, arg):
        return self.func(arg, *self.args, **self.kwargs)

def pipeable(f):
    @wraps(f)
    def _(*args, **kwargs):
        if f.__code__.co_argcount - 1 == len(args):
            return Ror(f, args, kwargs)
        else:
            return f(*args, **kwargs)

    return _

@pipeable
def psum(numbers):
    return sum(numbers)

@pipeable
def ppow(n, power):
    return n**power

print("Normal:", ppow(psum([1, 2, 3]), 10))
print(" Piped:", [1, 2, 3] | psum() | ppow(10))