How do I stop or cancel a task run?

[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?