Thomas Nakamoto
07/20/2021, 8:20 PMdef post_to_slack(task, old_state, new_state):
# <https://github.com/PrefectHQ/prefect/blob/d61fa6aac9330c5817cc8e8b8f8cca2d634ea7e1/src/prefect/engine/state.py>
if new_state.is_retrying():
msg = f"<@XXXX> {os.path.basename(__file__)} | {task} | {new_state}"
<http://requests.post|requests.post>("<https://hooks.slack.com/services/>", json={"text": msg})
if new_state.is_failed():
msg = f"<@XXXX> {os.path.basename(__file__)} | {task} | {new_state}"
<http://requests.post|requests.post>("<https://hooks.slack.com/services/>", json={"text": msg})
# if new_state.is_successful():
# msg = f"<@XXXX> {os.path.basename(__file__)} | {task} | {new_state}"
# <http://requests.post|requests.post>("<https://hooks.slack.com/services/>", json={"text": msg})
return new_state
I would like to avoid sending a success message for each task, and instead send one only if every task ran successfully. Thanks!Ben Muller
07/20/2021, 8:29 PMThomas Nakamoto
07/20/2021, 8:31 PMKevin Kho
Thomas Nakamoto
07/20/2021, 8:34 PMKevin Kho
Thomas Nakamoto
07/20/2021, 8:41 PM