Merge pull request strands-agents#43 from mehtarac/bidio_interface

Author: pgrayy

src/strands/experimental/bidi/agent/agent.py

@@ -422,20 +422,24 @@ async def run_outputs():
                     await output(event)
 
         for input_ in inputs:
-            await input_.start()
+            if hasattr(input_, "start"):
+                await input_.start()
 
         for output in outputs:
-            await output.start()
+            if hasattr(output, "start"):
+                await output.start()
 
         try:
             await asyncio.gather(run_inputs(), run_outputs(), return_exceptions=True)
 
         finally:
             for input_ in inputs:
-                await input_.stop()
+                if hasattr(input_, "stop"):
+                    await input_.stop()
 
             for output in outputs:
-                await output.stop()
+                if hasattr(output, "stop"):
+                    await output.stop()
 
     def _validate_active_connection(self) -> None:
         """Validate that an active connection exists.

src/strands/experimental/bidi/io/audio.py

@@ -17,7 +17,7 @@
 
 
 class _BidiAudioInput(BidiInput):
-    "Handle audio input from bidi agent."
+    """Handle audio input from bidi agent."""
     def __init__(self, audio: "BidiAudioIO") -> None:
         """Store reference to pyaudio instance."""
         self.audio = audio
@@ -43,7 +43,7 @@ async def __call__(self) -> BidiAudioInputEvent:
 
 
 class _BidiAudioOutput(BidiOutput):
-    "Handle audio output from bidi agent."
+    """Handle audio output from bidi agent."""
     def __init__(self, audio: "BidiAudioIO") -> None:
         """Store reference to pyaudio instance."""
         self.audio = audio
@@ -115,11 +115,11 @@ def __init__(
         self.interrupted = False
 
     def input(self) -> _BidiAudioInput:
-        "Return audio processing BidiInput"
+        """Return audio processing BidiInput"""
         return _BidiAudioInput(self)
 
     def output(self) -> _BidiAudioOutput:
-        "Return audio processing BidiOutput"
+        """Return audio processing BidiOutput"""
         return _BidiAudioOutput(self)
 
     def _start(self) -> None:

src/strands/experimental/bidi/io/text.py

@@ -9,7 +9,7 @@
 
 
 class _BidiTextOutput(BidiOutput):
-    "Handle text output from bidi agent."
+    """Handle text output from bidi agent."""
     async def __call__(self, event: BidiOutputEvent) -> None:
         """Print text events to stdout."""
 
@@ -25,7 +25,7 @@ async def __call__(self, event: BidiOutputEvent) -> None:
 
 
 class BidiTextIO:
-    "Handle text input and output from bidi agent."
+    """Handle text input and output from bidi agent."""
     def output(self) -> _BidiTextOutput:
         "Return text processing BidiOutput"
         return _BidiTextOutput()