Hi all: Using Prefect 1.x, is it possible to have timeout/expiration for late flow runs? We run an export job every 15 minutes, so if our agent goes down, these can accumulate rather quickly. When the agent comes back up, we do not want to go back and run all the missed scheduled runs, we just want to pick back up from wherever it is.

Yes see Automations. Specifically you can cancel a flow run if it is late by a certain amount of time using the Flow SLA

Thanks! Is this kind of ability Cloud only? e.g. if we are running our own Server, we could not clear these out except by hand?

Yes because it relies on services not shipped with Server. For Server, your best bet is implementing something like this to cancel all of the extra runs

I see ty! I am surprised there is no simple way to do this, but I should have done better research, hah. One my quick q if you have the time

Yes that’s right

Ok that’s more sane 🙂. Sounds like a reason to update to 2.0 sooner rather than later. Ty so much for the quick replies!

Of course!

Ah actually that’s not how

timeout_seconds

works — that’s a timeout on flow run time

🤔 What do you mean by “write a service”?

For v1 server I’d add an image to the docker-compose that queries for late runs in batches and updates their state, yeah

Subclass the agent sounds like getting into internals?