Runner

class pipecat.pipeline.runner.PipelineRunner(*, name=None, handle_sigint=True, force_gc=False, loop=None)

Bases: BaseObject

Parameters:

• name (str | None)

• handle_sigint (bool)

• force_gc (bool)

• loop (AbstractEventLoop | None)

async run(task)

Parameters:

task (PipelineTask)

async stop_when_done()

async cancel()