Merge branch 'main' into dev/integrate-observability

agency_swarm/messages/message_output.py

@@ -162,7 +162,9 @@ def cprint_update(self, snapshot):
         """
         Update the display with new snapshot content.
         """
-        self.content = snapshot  # Update content with the latest snapshot
+        self.content = (
+            snapshot or "No content available"
+        )  # Update content with the latest snapshot
 
         header_text = self.formatted_header
         md_content = Markdown(self.content)

agency_swarm/threads/thread.py

@@ -1,6 +1,7 @@
 import asyncio
 import inspect
 import json
+import logging
 import os
 import re
 import time
@@ -20,6 +21,8 @@
 from agency_swarm.util.streaming.agency_event_handler import AgencyEventHandler
 from agency_swarm.util.tracking.tracking_manager import TrackingManager
 
+logger = logging.getLogger(__name__)
+
 
 class Thread:
     async_mode: str = None
@@ -600,7 +603,7 @@ def _get_sync_async_tool_calls(self, tool_calls, recipient_agent):
             )
 
             if tool is None:
-                print(
+                logger.warning(
                     f"Tool {tool_call.function.name} not found in agent {recipient_agent.name}. Skipping."
                 )
                 continue

setup.py

@@ -6,7 +6,7 @@
 
 setup(
     name="agency-swarm",
-    version="0.4.3",
+    version="0.4.4",
     author="VRSEN",
     author_email="[email protected]",
     description="An opensource agent orchestration framework built on top of the latest OpenAI Assistants API.",