Hello guys! I am trying to execute a function on failure for a flow run but the arguments which admit are just flow, flow_run, state
I want to know the task name which fails and also the message value but I don't know how access to it.
Copy code
on_failure=[function_to_execute]
def function_to_execute(flow, flow_run, state):
#get task name an error
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.