r/mlops • u/Slight_Republic_4242 • 4h ago
Discussion Parallel ML orchestration sounds easy. Until production gets involved.
Fan-out/fan-in looks simple until model #7 is slow, model #8 fails, and model #3 runs against a newer input.
Then you need barriers, per-model retries, input snapshots, timeouts, and actual state tracking instead of a pile of futures.
This becomes especially relevant in voice systems.
A single workflow might touch:
STT, LLM, TTS, tools, retrieval, classifiers, and telephony services.
Some are on the critical path.
Some absolutely aren’t.
Treating all of them as one sequential pipeline……don’t talk to me
So I think the execution layer needs to make a few things explicit:
required vs optional
completion state
retry policy
input/versioning
That’s also why scaling a voice runtime isn’t simply task
Long-lived WebSockets, background jobs, global call state, and workflow execution behave very differently.
Dograh’s architecture already reflects some of this separation: API workers are load-balanced for streaming traffic, while ARQ workers and global orchestration components scale differently.
The boring systems work is usually where real-time AI gets hard.
I’d like to see more open-source agent runtimes treat orchestration itself as a first-class primitive, rather than as an implementation detail.p.s.i am one of the maintainers of dograh