plexus.processors.DeepgramTimeSliceProcessor module

class plexus.processors.DeepgramTimeSliceProcessor.DeepgramTimeSliceProcessor(**parameters)

Bases: Processor

Processor that filters Deepgram data in metadata to a time window.

Filters both the structured Deepgram JSON in metadata[‘deepgram’] and regenerates ScoreInput.text from the filtered data. This enables composable time-based slicing in the processor pipeline.

Parameters:

start: Start time in seconds (default: 0.0) end: End time in seconds (default: None = no limit) last: Last N seconds of the call. Reads total duration from

deepgram metadata. Overrides start/end if set.

Example usage in YAML:

item:

class: DeepgramInputSource options:

pattern: ‘.*deepgram.*.json$’ format: paragraphs include_raw_data: true

processors:

• class: DeepgramTimeSliceProcessor parameters:

  end: 60 # First 60 seconds

• class: DeepgramFormatProcessor parameters:

  format: sentences speaker_labels: true

Initialize the processor with configuration parameters.

Args:

**parameters: Processor-specific configuration parameters

process(score_input: Score.Input) → Score.Input

Transform a Score.Input.

Args:

score_input: Input to transform (contains text, metadata, results)

Returns:

Transformed Score.Input with modified text/metadata