Hey all! Simple question: if I raise an error with...
# prefect-communityd
Danny Vilela
03/25/2022, 7:29 PMHey all! Simple question: if I raise an error within a task (i.e.,
ValueError Copy code
# What I have now.
def notify_on_retry(task: Task, old_state: State, new_state: Retrying) -> State: ...
# Maybe what I want?
def notify_on_retry(task: Task, old_state: State, new_state: Retrying, message: str) -> State: ...
# Alternative?
def notify_on_retry(task: Task, old_state: State, new_state: Retrying, **kwargs) -> State: ...k
Kevin Kho
03/25/2022, 7:30 PM
Try retrieving it with
new_state.resultd
Danny Vilela
03/25/2022, 7:32 PMOhhhhhh okay. I can test it out real quick, but do you know if
new_state.resultValueErrork
Kevin Kho
03/25/2022, 7:33 PM
I think it is, maybe as JSON. I can test in a bit too
🙌 1
Kevin Kho
03/25/2022, 7:35 PM
Copy code
from prefect import Flow, task
import prefect
def handler(obj, old_state, new_state):
if new_state.is_failed():
<http://prefect.context.logger.info|prefect.context.logger.info>(new_state.result)
return new_state
@task(state_handlers=[handler])
def abc():
raise ValueError("MESSAGE HERE")
with Flow(",,") as flow:
abc()
flow.run()Kevin Kho
03/25/2022, 7:37 PM
You can try logging
type(new_state.result)new_state.result.message🙌 1
a
Anna Geller
03/25/2022, 8:43 PM
and if you want to e.g. send yourself a Slack message with a full traceback, check this example @Danny Vilela https://discourse.prefect.io/t/how-can-i-send-automated-failure-notifications-is-there-[…]t-a-full-exception-traceback-in-a-failure-notification/115
5 Views