Falk
jira_notifier
from prefect import task from prefect.utilities.notifications.jira_notification import jira_notifier @task(state_handlers=[ jira_notifier( only_states=[Failed], options={'project': 'TEST', 'issuetype': {'name': 'Bug'}}, assignee='tester' ) ]) def add(x, y): return x + y
Failed to load and execute flow run: NameError("name 'Failed' is not defined")
Sylvain Hazard
from prefect.engine.state import Failed
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.