Vadym Dytyniak
03/22/2022, 8:53 AMAnna Geller
03/22/2022, 9:15 AMVadym Dytyniak
03/22/2022, 9:19 AMAnna Geller
03/22/2022, 9:56 AMVadym Dytyniak
03/22/2022, 10:26 AMraise ENDRUN(
state=Failed(f'Failed to parse {file} with {FILE_PATTERN}'),
)
Anna Geller
03/22/2022, 11:01 AMfrom prefect.engine.signals import ENDRUN
from prefect.engine.state import Failed
from prefect import task
@task
def end_with_failure():
raise ENDRUN(Failed(message="your_message"))
Vadym Dytyniak
03/22/2022, 11:04 AM