Skip to content

test(frontend): pin zmq event plane in realtime Omni mock worker #16215

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
glamr-agent wants to merge 4 commits into
base: main
Choose a base branch
from
Open

test(frontend): pin zmq event plane in realtime Omni mock worker #16215

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
e3cc746
test(frontend): pin zmq event plane in realtime Omni mock worker
glamr-agent Oct 12, 2026
a3595de
chore: remove factory working notes
glamr-agent Oct 12, 2026
cf62314
docs(test): describe realtime mock worker entry point
glamr-agent Oct 12, 2026
1760988
Merge main to rerun CI
glamr-agent Oct 13, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion tests/frontend/realtime_omni_mock_worker.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,12 @@ async def generate(


async def main() -> None:
runtime = DistributedRuntime(asyncio.get_running_loop(), "file", "tcp")
"""Register and serve the mock realtime worker with an explicit ZMQ event plane."""
# Pass event_plane explicitly: DYN_EVENT_PLANE alone does not stop an ambient
# NATS_SERVER from forcing a NATS connection that retries for up to 120s.
runtime = DistributedRuntime(
asyncio.get_running_loop(), "file", "tcp", event_plane="zmq"
)
endpoint = runtime.endpoint(ENDPOINT_PATH)
handler = RealtimeOmniHandler(
engine_client=_MockAsyncOmni(),
Expand Down
8 changes: 5 additions & 3 deletions tests/frontend/test_realtime_omni_bridge.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -85,9 +85,11 @@ def realtime_omni_frontend(
"""Launch the frontend + mock-Omni worker; yield the frontend port once discovered.

Uses file-based discovery (the ``file_storage_backend`` fixture sets
``DYN_FILE_KV``), the tcp request plane, and an explicit zmq event plane, so
the two processes coordinate without etcd or nats and an ambient
``NATS_SERVER`` never forces a connection. Mirrors ``test_prompt_embeds.py``.
``DYN_FILE_KV``), the tcp request plane, and an explicit zmq event plane in
both processes (``--event-plane zmq`` for the frontend, ``event_plane="zmq"``
in ``realtime_omni_mock_worker.py``), so they coordinate without etcd or nats
and an ambient ``NATS_SERVER`` never forces a connection. Mirrors
``test_prompt_embeds.py``.
"""
_ = file_storage_backend # sets DYN_FILE_KV for both subprocesses
frontend_port = dynamo_dynamic_ports.frontend_port
Expand Down
Loading