How do I stop or cancel a task run?

[ahuang11]

The run seems to have crashed already, but it still shows running for 9 hours. Is there a way to manually stop the run?

It’s blocking all the other runs because I have concurrency set to 1

[anna_geller]

From flow code you could do:

How can I stop the task run based on a custom logic?

Prefect 2.0 In Orion, you can raise a custom exception directly in the flow, which will result in a Failed task run: from prefect import task @task def signal_task(message): if message == 'stop_immediately!': raise RuntimeError(message='Got a signal to end the task run!') Alternatively, your flow may return a specific state: from prefect import task from prefect.orion.schemas.states import Failed @task def signal_task(message): if message == 'stop_immediately!': ret…

But we don’t have a feature to cancel a run from the UI. And even if we would, this would allow canceling a flow run, not a task run. Does it answer your question?

[ahuang11]

Yeah I guess a cancel flow run would be nice (equivalent of a CTRL+C) for cases where the flow run is stuck or the flow run was run accidentally.

Or, I wonder if there’s a way to timeout task runs?

[anna_geller]

I agree! Canceling a flow run from the UI is a must-have, this will definitely be added.

Regarding task-level timeouts:

How can I set task-level timeouts in Prefect 2?

View in #prefect-community on Slack [Michael_Smith] @Michael_Smith: Hello, my prefect 2.0 tests are going well…I see that Flow has a timeout_seconds parameter, is there any way to set Task level timeouts as well? [Kevin_Kho] @Kevin_Kho: Orion doesn’t have timeouts yet so I don’t think there is a simple way like in Prefect 1 [Michael_Adkins] @Michael_Adkins: We don’t support cancellation of tasks at this time, but you can perform logic based on a wait/timeout future = my_task(arg, arg) state …