From f91179a64053d6e4916529cd001c387e6a7dd1b8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 21 May 2026 10:30:13 -0700 Subject: [PATCH] Forward `active` from PipelineWorker through to BaseWorker PipelineWorker.__init__ was only forwarding `name` to BaseWorker, so the `active` flag (the other BaseWorker constructor arg) wasn't reachable from PipelineWorker callers. Add `active: bool = True` to the signature and pass it through. --- src/pipecat/pipeline/worker.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/pipecat/pipeline/worker.py b/src/pipecat/pipeline/worker.py index c0e0feee5..8466cbaf3 100644 --- a/src/pipecat/pipeline/worker.py +++ b/src/pipecat/pipeline/worker.py @@ -204,6 +204,7 @@ class PipelineWorker(BaseWorker): self, pipeline: BasePipeline, *, + active: bool = True, additional_span_attributes: dict | None = None, app_resources: Any = None, bridged: tuple[str, ...] | None = None, @@ -230,6 +231,8 @@ class PipelineWorker(BaseWorker): Args: pipeline: The pipeline to execute. + active: Whether the worker starts active. Forwarded to + :class:`BaseWorker`. additional_span_attributes: Optional dictionary of attributes to propagate as OpenTelemetry conversation span attributes. app_resources: Optional application-defined bag of anything your @@ -276,7 +279,7 @@ class PipelineWorker(BaseWorker): Use ``app_resources`` instead. ``tool_resources`` will be removed in a future version. """ - super().__init__(name=name) + super().__init__(name=name, active=active) self._bridged = bridged if tool_resources is not None: with warnings.catch_warnings():