Feels like I'm trying to do something that prefect can do out of the box. Also I'm running into the scenario where I'm potentially awaiting the same coroutine from different callers. Anyone implement something like this in prefect?
Basically, I want to just run everything in graph traversal, create the futures, pass the futures downstream, and concurrently execute
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.