diff --git a/tests/test_langchain.py b/tests/test_langchain.py index 0f3ccdc86..cd4161f23 100644 --- a/tests/test_langchain.py +++ b/tests/test_langchain.py @@ -10,7 +10,7 @@ UserStoppedSpeakingFrame) from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner -from pipecat.pipeline.task import PipelineTask +from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_response import ( LLMAssistantResponseAggregator, LLMUserResponseAggregator) from pipecat.processors.frame_processor import FrameProcessor @@ -63,7 +63,7 @@ async def test_langchain(self): ] ) - task = PipelineTask(pipeline) + task = PipelineTask(pipeline, PipelineParams(allow_interruptions=False)) await task.queue_frames( [ UserStartedSpeakingFrame(),