Hi! If had some gRPC API endpoint that i wanted to trigger a Prefect workflow which runs a bunch of different models and collates and returns some results, what would be the best way to structure that? Something like this?

@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)

perhaps this way? https://discourse.prefect.io/t/how-to-create-a-flow-run-from-deployment-orchestrator-pattern/803

Thank you Anna! I’ll take a look 🙂