PipelineParams

from pipecat.pipeline.pipeline import Pipeline
from pipecat.pipeline.worker import PipelineParams, PipelineWorker

# Create with default parameters
params = PipelineParams()

# Or customize specific parameters
params = PipelineParams(
    audio_in_sample_rate=16000,
    enable_metrics=True
)

# Pass to PipelineWorker
pipeline = Pipeline([...])
worker = PipelineWorker(pipeline, params=params)

params = PipelineParams(
    audio_in_sample_rate=8000,   # Lower quality input audio
    audio_out_sample_rate=8000  # Lower quality output audio
)

params = PipelineParams(
    enable_heartbeats=True,
    heartbeats_period_secs=2.0,     # Send heartbeats every 2 seconds
    heartbeats_monitor_secs=15.0,   # Warn if heartbeat takes more than 15 seconds
    enable_metrics=True
)

from pipecat.observers.loggers.metrics_log_observer import MetricsLogObserver
from pipecat.pipeline.pipeline import Pipeline
from pipecat.pipeline.worker import PipelineParams, PipelineWorker
from pipecat.workers.runner import WorkerRunner

# Create comprehensive parameters
params = PipelineParams(
    audio_in_sample_rate=8000,
    audio_out_sample_rate=8000,
    enable_heartbeats=True,
    enable_metrics=True,
    enable_usage_metrics=True,
    heartbeats_period_secs=1.0,
    report_only_initial_ttfb=False,
    start_metadata={
        "conversation_id": "conv-123",
        "session_data": {
            "user_id": "user-456",
            "start_time": "2023-10-25T14:30:00Z"
        }
    }
)

# Create pipeline and worker
pipeline = Pipeline([...])
worker = PipelineWorker(
    pipeline,
    params=params,
    observers=[MetricsLogObserver()],
)

# Run the pipeline
runner = WorkerRunner()
await runner.add_workers(worker)
await runner.run()