Merge pull request #1988 from pipecat-ai/aleix/update-examples-22b
examples(22b): remove unnecessary parallel pipeline branch
This commit is contained in:
@@ -312,9 +312,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
|
|||||||
# to start the conversation.
|
# to start the conversation.
|
||||||
bot_output_gate = OutputGate(notifier=notifier, start_open=True)
|
bot_output_gate = OutputGate(notifier=notifier, start_open=True)
|
||||||
|
|
||||||
async def block_user_stopped_speaking(frame):
|
|
||||||
return not isinstance(frame, UserStoppedSpeakingFrame)
|
|
||||||
|
|
||||||
async def pass_only_llm_trigger_frames(frame):
|
async def pass_only_llm_trigger_frames(frame):
|
||||||
return (
|
return (
|
||||||
isinstance(frame, OpenAILLMContextFrame)
|
isinstance(frame, OpenAILLMContextFrame)
|
||||||
@@ -331,11 +328,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
|
|||||||
stt,
|
stt,
|
||||||
context_aggregator.user(),
|
context_aggregator.user(),
|
||||||
ParallelPipeline(
|
ParallelPipeline(
|
||||||
[
|
|
||||||
# Pass everything except UserStoppedSpeaking to the elements after
|
|
||||||
# this ParallelPipeline
|
|
||||||
FunctionFilter(filter=block_user_stopped_speaking),
|
|
||||||
],
|
|
||||||
[
|
[
|
||||||
# Ignore everything except an OpenAILLMContextFrame. Pass a specially constructed
|
# Ignore everything except an OpenAILLMContextFrame. Pass a specially constructed
|
||||||
# LLMMessagesFrame to the statement classifier LLM. The only frame this
|
# LLMMessagesFrame to the statement classifier LLM. The only frame this
|
||||||
|
|||||||
Reference in New Issue
Block a user