Santiago Gonzalez
02/08/2022, 9:45 PMKevin Kho
Santiago Gonzalez
02/08/2022, 9:47 PMKevin Kho
slack_notification
right?Kevin Kho
from prefect.engine.state import Paused
def post_to_slack_on_failure(task, old_state, new_state):
if isinstance(new_state, Paused):
SlackTask(message=msg).run()
return new_state
Kevin Kho
prefect.context.get("task_run_id")
to construct as URL to include in the messageSantiago Gonzalez
02/08/2022, 9:54 PMSantiago Gonzalez
02/10/2022, 5:48 PM