npx skills add ...
npx skills add deepgram/deepgram-python-sdk --skill deepgram-python-conversational-stt
npx skills add deepgram/deepgram-python-sdk --skill deepgram-python-conversational-stt
Use when writing or reviewing Python code in this repo that calls Deepgram Conversational STT v2 / Flux (`/v2/listen`) for turn-aware streaming transcription. Covers `client.listen.v2.connect(...)`, Flux models, end-of-turn detection. Use `deepgram-python-speech-to-text` for standard v1 ASR, `deepgram-python-voice-agent` for full-duplex interactive assistants. Triggers include "flux", "v2 listen", "conversational STT", "turn detection", "end of turn", "EOT", "listen.v2", "flux-general-en", "flux-general-multi".
Turn-aware streaming STT at /v2/listen — optimized for conversational audio (end-of-turn detection, eager EOT, barge-in scenarios).
Use a different skill when:
deepgram-python-speech-to-text.deepgram-python-voice-agent.deepgram-python-audio-intelligence.Header: Authorization: Token <api_key>. WSS only — no REST path on v2.
| Param | Notes |
|---|---|
model | flux-general-en (English) or flux-general-multi (multilingual) — REQUIRED, must be a Flux model |
encoding | linear16, mulaw, etc. Omit for containerized audio |
sample_rate | String in the SDK signature, e.g. "16000" |
eager_eot_threshold | Fire end-of-turn early at this confidence |
eot_threshold | Primary end-of-turn confidence |
eot_timeout_ms | Time-based fallback turn end |
keyterm | Bias for domain keywords |
mip_opt_out, tag | Metadata / privacy flags |
language_hint | ONLY for flux-general-multi |
authorization, request_options | Override auth or request options |
No language parameter on v2 — language is implied by model (flux-general-en) or hinted via language_hint on multi.
ListenV2Connected — connection establishedListenV2ConfigureSuccess / ListenV2ConfigureFailure — mid-session config changesListenV2TurnInfo — per-turn transcript + event (Update, EndOfTurn, EagerEndOfTurn, ...) + turn_indexListenV2FatalError — terminal errorClient messages: ListenV2Media, ListenV2Configure, ListenV2CloseStream.
reference.md — "Listen V2 Connect"./llmstxt/developers_deepgram_llms_txt./v2/listen, not /v1/listen. Different route, different client path (listen.v2 vs listen.v1).nova-3, base, etc. will be rejected. Use flux-general-en or flux-general-multi.language parameter. Language is set by model choice. Use language_hint on flux-general-multi.sample_rate is a STRING in the SDK (e.g. "16000").send_close_stream(ListenV2CloseStream(type="CloseStream")) — not send_finalize (that's v1).construct_type for unknowns. Handle both branches (see socket_client.py patch in .fernignore).socket_client.py is patched / frozen (see .fernignore → src/deepgram/listen/v2/socket_client.py). Don't overwrite that manual patch during regeneration; treat other listen/v2 files as generated unless the regen workflow says otherwise.encoding/sample_rate for containerized audio (WAV, OGG, etc.) — the server detects them from the container.examples/14-transcription-live-websocket-v2.pytests/manual/listen/v2/connect/main.pydeepgram-python-speech-to-text — v1 general-purpose STT (REST + WSS)deepgram-python-voice-agent — full interactive assistantFor cross-language Deepgram product knowledge — the consolidated API reference, documentation finder, focused runnable recipes, third-party integration examples, and MCP setup — install the central skills:
This SDK ships language-idiomatic code skills; deepgram/skills ships cross-language product knowledge (see api, docs, recipes, examples, starters, setup-mcp).
import threading, time
from pathlib import Path
from deepgram.core.events import EventType
from deepgram.listen.v2.types import (
ListenV2CloseStream,
ListenV2Connected,
ListenV2FatalError,
ListenV2TurnInfo,
)
with client.listen.v2.connect(
model="flux-general-en",
encoding="linear16",
sample_rate="16000",
) as conn:
def on_message(m):
if isinstance(m, ListenV2TurnInfo):
print(f"turn {m.turn_index} [{m.event}] {m.transcript}")
elif isinstance(m, dict): # untyped fallback
if m.get("type") == "TurnInfo":
print(f"turn {m.get('turn_index')} [{m.get('event')}] {m.get('transcript')}")
else:
print(f"event: {getattr(m, 'type', type(m).__name__)}")
conn.on(EventType.OPEN, lambda _: print("open"))
conn.on(EventType.MESSAGE, on_message)
conn.on(EventType.CLOSE, lambda _: print("close"))
conn.on(EventType.ERROR, lambda e: print(f"err: {type(e).__name__}: {e}"))
def send_audio():
for chunk in mic_chunks(): # 80ms recommended
conn.send_media(chunk)
time.sleep(0.01)
conn.send_close_stream(ListenV2CloseStream(type="CloseStream"))
threading.Thread(target=send_audio, daemon=True).start()
conn.start_listening()from deepgram import AsyncDeepgramClient
client = AsyncDeepgramClient()
async with client.listen.v2.connect(model="flux-general-en", ...) as conn:
# same .on(...) handlers, then:
await conn.start_listening()npx skills add deepgram/skills