Michael Ludwig
07/29/2020, 6:39 PMNone
):
end_state = flow.run(executor=executor,)
for result in end_state.result:
<http://logger.info|logger.info>(f"Result: {result} -> {result.result}")
Flow run SUCCESS: all reference tasks succeeded
Result: <Task: user-to-cluster-snowflake-loader-free> -> None
Result: <Task: asp_ssm_parameter_writer> -> None
Result: <Task: mood_scorer> -> None
Result: <Task: rfy_predictor_FREE> -> None
Result: <Task: rfy_bucket_prefix_updater_Variants.main> -> None
Any ideas? Not using the newer Result
construct though but would be great to grab the return values at the end of the flow runjosh
07/29/2020, 6:48 PMend_state.result
is a dictionary so you need to iterate over the key value pair 🙂
for key, value in end_state.result.items():
<http://logger.info|logger.info>(f"Result: {key} -> {value.result}")
Task
so your snippet is grabbing the result attribute of the task class (which is None) and the value is the state from the task run (which has a result)Michael Ludwig
07/29/2020, 7:04 PMjosh
08/03/2020, 12:13 PM