pipeline-fn-test.py

from functools import partial


def step(original):
    def wrapper(*args, **kwargs):
        return partial(original, *args, **kwargs)
    return wrapper


def pipe(initial, *fns):
    carry = initial

    for fn in fns:
        carry = fn(carry)

    return carry


@step
def fn1(i: int):
    return i + 1


@step
def fn2(i: int):
    return i * 2


@step
def fn3(i: int):
    return i ** 2


@step
def fn4(i: int, n: int = 1):
    return i * n


pipe(
    70,
    fn1(),
    fn4(n=10),
    fn4(n=3),
    fn3(),
)  # 4536900