Jake Schmidt
12/18/2019, 10:51 PMresult
of a given task in a flow? I see that flow.run().result
is a dict
keyed by `Task`s but flow.run().result[prefect.Task('task_name')]
gives a KeyError
. I can’t find the answer in the documentation or the api reference for State
.Jeremiah
12/18/2019, 10:51 PMresult
attribute by the task itself: flow.run().result[your_task].result
flow.run()
returns a State
for the flow, and that state has a result dict. Each value of the result dict is the final State
of the corresponding task key, and each of those states has its own stored resultJackson Maxfield Brown
12/18/2019, 10:52 PM# Run the flow
state = flow.run(executor=executor)
# Get resulting path
save_path = state.result[flow.get_tasks(name="_get_save_path")[0]].result
Jeremiah
12/18/2019, 10:53 PMflow.get_tasks(name=X)[0]
will return it for youJake Schmidt
12/18/2019, 10:57 PM