kasteph
retries
retry_delay_seconds
flow
_pickle.PicklingError: Pickling client objects is explicitly not supported.
@task def first(): return 1 @task def add_one(n): return n + 1 @flow(retries=3, retry_delay_seconds=10) def add_one_plus_one(): f = first() a = add_one(n, wait_for[f]) return a
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.