kasteph
07/05/2023, 6:19 PMretries
and retry_delay_seconds
with the flow
decorator, I get the following error when running a task within the flow:
_pickle.PicklingError: Pickling client objects is explicitly not supported.
However removing those parameters will make the flow run just fine. Has anyone else encountered this?@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