Result of pushing a configuration change to the upstream provider. Used by ``configure_inbound`` (and similar provider-side syncs) so callers

One form field for the telephony configuration UI. Used to generate provider-specific config forms without per-provider UI code. Field semant

Manager for custom tool registration and execution. This class handles: 1. Fetching tools from the database based on tool UUIDs 2. Co

Sliding window circuit breaker for campaign call failures.

Result of a quota check.

A topic's framing for one stage. Either marked irrelevant, or carries 1–3 lines of stage-specific guidance pointing at the atom's full content

Mock tool model for testing.

*All* business invariants (acyclic, cardinality, etc.) are verified here. The constructor accepts a validated ReactFlowDTO.

Typed builder that produces `ReactFlowDTO`-compatible JSON. Usage: wf = Workflow(client=client, name="loan_qual") start = wf.add(

One live MCP server connection for the duration of a call.

Normalized status callback shape used across all telephony providers. Provider-specific route handlers map raw webhook payloads into this shape,

Intent-level check — requires LLM judgment via `/audit_voice_prompts`. The judge agent answers `judge_question` yes/no against the prompt bei

Manages rate-limited and concurrent-limited call dispatching

HTTP client for managing service keys via MPS API.

Centralized audio configuration for the pipeline. Note: Pipeline is limited to 16kHz maximum to support VAD. Transports handle resampling fro

Helper class to track end call related state during tests.

Raised when node data fails client-side validation (unknown field, missing required field, obvious type mismatch). Server-side Pydantic valid

Result of source validation.

Represents a validation error with details.

One atom of voice-prompting guidance. `content` is the single source of truth. Lenses, llm_hints, signals, and checks reference this atom by

Standardized response from initiate_call across all providers.

Standardized inbound call data across all providers.

Everything needed to plug a telephony provider into the platform. Attributes: name: Stable identifier (e.g., "twilio"). Used as the discr

Display metadata for a provider's configuration form.

Request schema for creating a reusable tool.

Gender prediction result.

Audio bytes paired with the recording's transcript (when available).

Recoverable tool-management error with an MCP/HTTP friendly code.

Event data structure for transfer coordination.

Audio streaming configuration.

Streams audio files as PCM16 chunks. Converts any audio format to raw PCM16 using ffmpeg and streams in real-time chunks to simulate live aud

Per-user onboarding state, stored under UserConfigurationKey.ONBOARDING. Server-authoritative replacement for the browser-localStorage onboarding

An option in an `options` or `multi_options` dropdown.

Manages call transfer events and context storage using Redis.

Sync HTTP client. Suitable for scripts, pytest, and the LLM SDK exec sandbox. Auth precedence: 1. `api_key` kwarg 2. `DOGRAH_

Internal service for predicting gender from names. Uses local SSA-based model with GenderAPI fallback.

Mock tool model for testing.

Observer that sends real-time events via WebSocket and persists final transcripts. WebSocket streaming (all events for live UI): - User trans

Result from STT transcription.

Represents a transcribed word with metadata.

Conditional visibility rules. `show` keys are AND-combined: this property is visible only when EVERY referenced field's value matches one of

Response schema for document metadata.

Use Gemini's full JSON Schema tool parameter field. Pipecat's default Gemini adapter maps ``FunctionSchema.parameters`` into ``FunctionDeclar

OpenAI Realtime with Dograh engine integration quirks. See module docstring.

Dograh-friendly OneShot params with string voice support.

Buffer audio data in memory during a call, then encode to WAV bytes on disconnect.

Raised when an MCP tool definition is structurally invalid.

Mock end call tool model for testing.

Opaque handle returned by `Workflow.add()`. Passed to `edge()` to wire nodes together without relying on string IDs.

Partial update merged into the stored state. Scalars overwrite when supplied; list entries are unioned into the stored lists, so concurrent u

Raised when no phone numbers are available in the pool for outbound calls.

Result of pushing a phone-number change to the upstream provider. Returned alongside create/update responses when the route attempted to sync

What comes back from an operation. `class_name` is a model class from `_generated_models`; `is_list` wraps it as a list.