Hey! I'm currently working with the PrefectFutures object right now and building off of what I found on a forum post of:
Copy code
task_future.wait()
if task_future.get_state().is_failed():
name_ = task_future.task_run.name
id_ = task_future.task_run.flow_run_id
<http://requests.post|requests.post>(
SLACK_WEBHOOK_URL,
json={"text": f"The task `{name_}` failed in a flow run `{id_}`"},
)
Though, I was thinking it'd be wildly helpful for there to also be a way we could also include the error log in there. Is there a way for the error log to be posted to the slack_webhook_url?
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.