Tom Matthews
07/01/2022, 9:42 AM@flow
def pipeline(request):
# bunch of tasks, some of which run in parallel
# flow and tasks defined in another script
return output
...
def some_grpc_api_endpoint(request):
return pipeline(request)
Anna Geller
07/01/2022, 11:29 AMTom Matthews
07/01/2022, 1:20 PM