kiran
09/13/2022, 5:43 PMRob Freedy
09/13/2022, 9:00 PMkiran
09/26/2022, 4:28 PM@flow(retries=2, retry_delay_seconds=60)
def final_flow(main_flow) -> None:
slack_webhook_block = SlackWebhook.load("slack")
logger = get_run_logger()
state = main_flow()
final_state = state[-1]
if final_state.is_failed():
<http://logger.info|logger.info>(final_state.is_failed())
slack_webhook_block.notify("failed")
elif final_state.is_completed():
<http://logger.info|logger.info>(final_state.is_completed())
slack_webhook_block.notify("completed")
return
Rob Freedy
09/26/2022, 9:44 PMkiran
09/29/2022, 3:08 AM@flow
def final_flow():
try:
main_flow()
except Exception:
fail_notify_flow("#prefect", "insert_flow_name")
else:
success_notify_flow("#prefect", "insert_flow_name")
if __name__ == "__main__":
final_flow()