Santiago Gonzalez
02/08/2022, 9:45 PMKevin Kho
02/08/2022, 9:45 PMSantiago Gonzalez
02/08/2022, 9:47 PMKevin Kho
02/08/2022, 9:48 PMslack_notification
right?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
prefect.context.get("task_run_id")
to construct as URL to include in the messageSantiago Gonzalez
02/08/2022, 9:54 PM