Hello guys! I'm using this example : https://docs.prefect.io/core/examples/functional_docker.html and I would like to know if it's possible to add a retry if python job fail - I saw how to do it with a task but not CreateContainer function

CreateContainer

is a subclass of

Task

which takes arguments related to retries - so you should just be able to pass those down?

Yup you can pass those kwargs when instantiating the task - using that doc as an example:

from datetime import timedelta

container = CreateContainer(
    image_name="prefecthq/prefect",
    command='''python -c "from prefect import Flow; f = Flow('empty'); f.run()"''',
    max_retries=3,
    retry_delay=timedelta(seconds=2)
)

thanks for your feedbacks @josh @Kyle Moon-Wright

Hmm, well the retry will kick in if the State of the task has ended in failure. In this case, the command may have succeeded in executing even though the container creation failed..? I certainly expected the CreateContainer failure to bubble to the task - does that seem to be the case here? edit: Hmm I’m unable to reproduce, but we may need to separate the command logic part specifically.

did you

command='''python -c "from prefect import Flow; f = Flow('empty');

by making

command='''python -c "from prefect2222 import Flow; f = Flow('empty');

Gotcha, I was just looking at the WaitOnContainer task. It’s working as expected with the retry logic there instead?

yes!

I gladly accept the credit, and none of the blame…