Skip to content

feat(streaming): add speech-events topic #55

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

Merged
jrb00013 merged 3 commits into from
Aug 26, 2026
Merged

feat(streaming): add speech-events topic #55

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
44a56ef
feat(streaming): add speech-events to StreamTopics allowlist
jrb00013 Aug 25, 2026
a5c92fa
test(streaming): assert speech-events in allowlist
jrb00013 Aug 25, 2026
c3456a6
docs(streaming): clarify sugar_glider_allowlist returns stream topics
jrb00013 Aug 25, 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
8 changes: 7 additions & 1 deletion src/deepiri_modelkit/streaming/topics.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,8 @@ class StreamTopics(str, Enum):
PIPELINE_SPLICE_EVENTS = "pipeline.splice.events"
PIPELINE_DEAD_LETTER = "pipeline.dead-letter"
PIPELINE_METRICS = "pipeline.metrics"
# Speech plane (deepiri-speech STT/TTS / LiveKit session events).
SPEECH_EVENTS = "speech-events"

@classmethod
def all(cls) -> list:
Expand All @@ -36,5 +38,9 @@ def all(cls) -> list:

@classmethod
def sugar_glider_allowlist(cls) -> list:
"""Canonical SIDECAR_PUBLISH/CONSUME stream list for compose."""
"""Canonical Redis stream topic names for Sugar Glider compose allowlists.

Used as ``SUGAR_GLIDER_PUBLISH_STREAMS`` / ``SIDECAR_PUBLISH_STREAMS``
(and the matching CONSUME lists). Returns every ``StreamTopics`` value.
"""
return cls.all()
3 changes: 3 additions & 0 deletions tests/test_streaming_topics.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,4 +41,7 @@ def test_all_includes_shared_stream_topics() -> None:
assert "pipeline.artifact.invalidation" in topics
assert "pipeline.splice.events" in topics
assert "training-jobs" in topics
assert "speech-events" in topics
assert StreamTopics.SPEECH_EVENTS.value == "speech-events"
assert len(StreamTopics.sugar_glider_allowlist()) == len(topics)
assert "speech-events" in StreamTopics.sugar_glider_allowlist()
Loading