https://prefect.io logo
x

xyzy

03/31/2021, 3:44 AM
Is there a library that allows you to write flows like this:
Copy code
chain(
        extract(from_date, to_date, base_currency), 
        transform, 
        load
    )
Instead of this:
Copy code
extract_result = extract(from_date, to_date, base_currency)
    transform_result = transform(extract_result)
    load(transform_result)
?
Found a thread referring to https://toolz.readthedocs.io/en/latest/api.html#toolz.functoolz.pipe which does the trick
would love to see this functionality integrated in the core so you don't need an external library