martin hablak
06/29/2022, 8:38 AMflow_run_reference = flow.run()
for result in flow_run_reference.task_results:
yield result.json()
basically stream tasks result using say fastapi as soon as it finishes not waiting until whole flow finishAnna Geller
06/30/2022, 11:53 AMmartin hablak
06/30/2022, 3:04 PM