Hi everyone - how is `timeout` supposed to work on a mapped task ? it seems to me that timeout is no...

Marwan Sarieddine

05/22/2020, 10:53 PM

Hi everyone - how is

timeout

supposed to work on a mapped task ? it seems to me that timeout is not being enforced - is there a way to see the timeout specification in the UI ?

Chris White

05/22/2020, 10:58 PM

Hey Marwan - at a high level, your timeout will apply on each individual task of your mapped task. However, because it is not entirely possible to stop an arbitrary python function, Prefect operates on a best effort basis — either way though, if your specified

timeout

is exceeded your task should enter a

TimedOut

failed state. If you’re seeing otherwise I’d be curious for a reproducible example!

Marwan Sarieddine

05/22/2020, 10:59 PM

Hi @Chris White - thank you for the quick response - I am not seeing my tasks enter a

TimedOut

failed state for some reason - will try to share an example soon

👍 1

Marwan Sarieddine

05/23/2020, 3:31 PM

here is the link to the issue which hopefully describes what I am trying to do (and where I would have expected the timeout to be invoked) along with a reproducible example https://github.com/PrefectHQ/prefect/issues/2645

👍 1

Open in Slack

Previous Next

Prefect Community

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.