diff --git a/examples/foundational/22b-natural-conversation-proposal.py b/examples/foundational/22b-natural-conversation-proposal.py index 290f6624c..a520d17be 100644 --- a/examples/foundational/22b-natural-conversation-proposal.py +++ b/examples/foundational/22b-natural-conversation-proposal.py @@ -237,6 +237,9 @@ class TurnDetectionLLM(Pipeline): or isinstance(frame, FunctionCallResultFrame) ) + async def filter_all(frame): + return False + super().__init__( [ ParallelPipeline( @@ -247,6 +250,7 @@ class TurnDetectionLLM(Pipeline): statement_judge_context_filter, statement_llm, completeness_check, + FunctionFilter(filter=filter_all, direction=FrameDirection.UPSTREAM), ], [ # Block everything except frames that trigger LLM inference. diff --git a/examples/foundational/22c-natural-conversation-mixed-llms.py b/examples/foundational/22c-natural-conversation-mixed-llms.py index 83c153f80..80811c2e7 100644 --- a/examples/foundational/22c-natural-conversation-mixed-llms.py +++ b/examples/foundational/22c-natural-conversation-mixed-llms.py @@ -431,6 +431,9 @@ class TurnDetectionLLM(Pipeline): or isinstance(frame, FunctionCallResultFrame) ) + async def filter_all(frame): + return False + super().__init__( [ ParallelPipeline( @@ -446,6 +449,7 @@ class TurnDetectionLLM(Pipeline): statement_judge_context_filter, statement_llm, completeness_check, + FunctionFilter(filter=filter_all, direction=FrameDirection.UPSTREAM), ], [ # Block everything except frames that trigger LLM inference.