Tom Matthews

07/01/2022, 9:42 AM
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?
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)
✅ 1

Tom Matthews

07/01/2022, 1:20 PM
Thank you Anna! I’ll take a look 🙂
🙌 1