Merge pull request #1512 from pipecat-ai/mb/fix-gemini-examples

Examples: Fix context_aggregator.assistant() pipeline position

examples/foundational/19a-azure-realtime-beta.py

@@ -147,8 +147,8 @@ Remember, your responses should be short. Just one or two sentences, usually."""
                 transport.input(),  # Transport user input
                 context_aggregator.user(),
                 llm,  # LLM
-                context_aggregator.assistant(),
                 transport.output(),  # Transport bot output
+                context_aggregator.assistant(),
             ]
         )
 

examples/foundational/20a-persistent-context-openai.py

@@ -205,8 +205,8 @@ async def main():
                 context_aggregator.user(),
                 llm,  # LLM
                 tts,
-                context_aggregator.assistant(),
                 transport.output(),  # Transport bot output
+                context_aggregator.assistant(),
             ]
         )
 

examples/foundational/20b-persistent-context-openai-realtime.py

@@ -230,8 +230,8 @@ Remember, your responses should be short. Just one or two sentences, usually."""
                 transport.input(),  # Transport user input
                 context_aggregator.user(),
                 llm,  # LLM
-                context_aggregator.assistant(),
                 transport.output(),  # Transport bot output
+                context_aggregator.assistant(),
             ]
         )
 

examples/foundational/20c-persistent-context-anthropic.py

@@ -202,8 +202,8 @@ async def main():
                 context_aggregator.user(),
                 llm,  # LLM
                 tts,
-                context_aggregator.assistant(),
                 transport.output(),  # Transport bot output
+                context_aggregator.assistant(),
             ]
         )
 

examples/foundational/20d-persistent-context-gemini.py

@@ -261,8 +261,8 @@ async def main():
                 context_aggregator.user(),
                 llm,  # LLM
                 tts,
-                context_aggregator.assistant(),
                 transport.output(),  # Transport bot output
+                context_aggregator.assistant(),
             ]
         )
 

examples/foundational/26b-gemini-multimodal-live-function-calling.py

@@ -110,8 +110,8 @@ async def main():
                 transport.input(),
                 context_aggregator.user(),
                 llm,
-                context_aggregator.assistant(),
                 transport.output(),
+                context_aggregator.assistant(),
             ]
         )