kent
@task def my_favorite_function(): raise ValueError("This flow immediately fails") @task def one_return(): return 1 @task def tow_return(): return 2 @flow def run_flow(): my_favorite_function() one_return() tow_return()
Christopher Boyd
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.