Runner¶
ghost_brain.modules.pipeline.runner
¶
Pipeline runner and event handlers: connect, disconnect, transcript upload.
logger = logging.getLogger(__name__)
module-attribute
¶
register_handlers(transport: FastAPIWebsocketTransport, task: PipelineTask, context: LLMContext, settings: Settings, session_id: str) -> None
¶
Register transport event handlers for client connect and disconnect.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
transport
|
FastAPIWebsocketTransport
|
The WebSocket transport for handling connections. |
required |
task
|
PipelineTask
|
The active pipeline task. |
required |
context
|
LLMContext
|
LLM context containing conversation history. |
required |
settings
|
Settings
|
Application settings. |
required |
session_id
|
str
|
The unique identifier for the current session. |
required |
run_pipeline(task: PipelineTask) -> None
async
¶
Execute the pipeline task.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
task
|
PipelineTask
|
The configured pipeline task to run. |
required |