https://prefect.io logo
k

kasteph

07/05/2023, 6:19 PM
When I configure
retries
and
retry_delay_seconds
with the
flow
decorator, I get the following error when running a task within the flow:
Copy code
_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?
Here's an example of the code block:
Copy code
@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