Vaibhav Ariyur
12/02/2021, 8:10 PMon_failure
param of a flow? Should the function called by on_failure
be able to read your flow's results?Kevin Kho
12/02/2021, 8:12 PMdef st_handler(task, old_state, new_state):
...
You can try doing new_state.result
to get the result. What kind of parameters are you trying to pass?Vaibhav Ariyur
12/02/2021, 8:14 PMdef *clean_on_failure*(flow: *Flow*, state: *State*)
and I am trying to pass the directory to removeKevin Kho
12/02/2021, 8:16 PMflow.run()
you will see them but when running with a backend (Server or Cloud), they are not stored.Vaibhav Ariyur
12/02/2021, 8:20 PMKevin Kho
12/02/2021, 8:27 PMVaibhav Ariyur
12/02/2021, 8:28 PMKevin Kho
12/02/2021, 8:35 PMprefect.context.parameters
Vaibhav Ariyur
12/02/2021, 8:37 PMKevin Kho
12/02/2021, 8:38 PMdef st_handler(flow, old_state, new_state):
myparam = prefect.context.parameters.get("myparam")
something like thisVaibhav Ariyur
12/02/2021, 8:43 PMKevin Kho
12/02/2021, 8:45 PM