plexus.input_sources.InputSource module

class plexus.input_sources.InputSource.InputSource(pattern: str = None, **options)

Bases: ABC

Base class for input sources that extract text from various sources. Input sources run BEFORE processors in the pipeline.

Args:: pattern: Regex pattern to match attachments (used by file-based sources) **options: Additional source-specific options

__init__(pattern: str = None, **options)

Args:: pattern: Regex pattern to match attachments (used by file-based sources) **options: Additional source-specific options

abstractmethod extract(item) → Score.Input

Extract Score.Input from the specified source.

This method is the core of the input source pipeline. It takes an Item and produces a Score.Input with text and metadata populated.

Args:

item: Item object (may have attachedFiles, text, metadata)

Returns:

Score.Input with text field and metadata populated

Example:

class MyInputSource(InputSource):

def extract(self, item):

# Extract text from source text = self.get_text_from_source(item)

# Build metadata metadata = item.metadata or {} metadata[‘source’] = ‘MyInputSource’

# Return Score.Input from plexus.scores.Score import Score return Score.Input(text=text, metadata=metadata)

find_matching_attachment(item) → str | None

Find first attachment matching the regex pattern.