Hawkar Mahmod
08/19/2022, 2:28 PMAnna Geller
Failed
task run:
from prefect import task
@task
def signal_task(message):
if message == 'stop_immediately!':
raise RuntimeError(message='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!':
return Failed(message='Stopping the task run immediately!')