John Ramirez
Chris White
State
flow_state = flow.run() flow_state.result # a dictionary of Tasks -> States flow_state.result[my_task].result # the result of a task in the flow
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.