chore: Release 1.7.8 (#4092)

# Changelog

## New Features:
- **Output model**: Added support for `output_model` on Agents and Teams
to generate the final response from `output_model` instead of `model`

## Improvements:

- **Support for OpenAI Flex Processing**: Added `service_tier` to
`OpenAIChat` and `OpenAIResponses`.

## Bug Fixes:

- **Print Response:**
    - Fixed `show_member_responses` not working correctly on `Team`
    - Fixed printing of MCP responses on streamable HTTP
- **Session State on Team**: Fixed precedence for session state from
sessions DB.
- **`YouTubeTranscriptApi` has no attribute `get_transcript` :**
- The `YoutubeTranscriptApi` is updated and now uses `.fetch(video_id)`
for getting transcripts.
- **HITL streaming:**
- Added the required attributes- `tools_requiring_confirmation`,
`tools_requiring_user_input`, `tools_awaiting_external_execution` on the
class `BaseAgentRunResponseEvent`
- If you are using streaming, it is recommended to pass the `run_id` and
a list of `updated_tools` to the `continue_run` or `acontinue_run`
method.

---------

Co-authored-by: Yash Pratap Solanky <101447028+ysolanky@users.noreply.github.com>
Co-authored-by: ysolanky <yash@phidata.com>

Author: dirkbrnd

libs/agno/agno/team/team.py

@@ -5689,6 +5689,13 @@ def _get_user_message(
                 return Message.model_validate(message)
             except Exception as e:
                 log_warning(f"Failed to validate message: {e}")
+        elif isinstance(message, BaseModel):
+            try:
+                # Create a user message with the BaseModel content
+                content = message.model_dump_json(indent=2, exclude_none=True)
+                return Message(role="user", content=content)
+            except Exception as e:
+                log_warning(f"Failed to convert BaseModel to message: {e}")
 
     def get_messages_for_parser_model(
         self, model_response: ModelResponse, response_format: Optional[Union[Dict, Type[BaseModel]]]
@@ -7119,9 +7126,10 @@ def load_team_session(self, session: TeamSession):
                     # If the session_state is already set, merge the session_state from the database with the current session_state
                     if self.session_state is not None and len(self.session_state) > 0:
                         # This updates session_state_from_db
-                        merge_dictionaries(session_state_from_db, self.session_state)
-                    # Update the current session_state
-                    self.session_state = session_state_from_db
+                        merge_dictionaries(self.session_state, session_state_from_db)
+                    else:
+                        # Update the current session_state
+                        self.session_state = session_state_from_db
 
             if "team_session_state" in session.session_data:
                 team_session_state_from_db = session.session_data.get("team_session_state")

libs/agno/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "agno"
-version = "1.7.7"
+version = "1.7.8"
 description = "Agno: a lightweight library for building Multi-Agent Systems"
 requires-python = ">=3.7,<4"
 readme = "README.md"

libs/agno/tests/integration/teams/test_event_streaming.py

@@ -139,7 +139,7 @@ def test_intermediate_steps_with_tools():
     assert len(events[TeamRunEvent.run_response_content]) > 1
     assert len(events[TeamRunEvent.run_completed]) == 1
     assert len(events[TeamRunEvent.tool_call_started]) == 1
-    assert events[TeamRunEvent.tool_call_started][0].tool.tool_name == "get_current_stock_price"
+    assert events[TeamRunEvent.tool_call_started][0].tool.tool_name == "get_current_stock_price" or "transfer_task_to_member"
     assert len(events[TeamRunEvent.tool_call_completed]) == 1
     assert events[TeamRunEvent.tool_call_completed][0].content is not None
     assert events[TeamRunEvent.tool_call_completed][0].tool.result is not None

libs/agno/tests/integration/teams/test_team_session_state.py

@@ -1,3 +1,4 @@
+import uuid
 import pytest
 
 from agno.models.openai.chat import OpenAIChat
@@ -142,3 +143,49 @@ def test_team_session_state_on_run(route_team):
         "test_key": "test_value",
         "something_else": "other_value",
     }, "Merging session state should work"
+
+
+def test_session_state_db_precedence(route_team, team_storage):
+    """Test that DB session_state takes precedence over agent's in-memory session_state when switching sessions."""
+    # Set up two sessions with different session_state
+    session_id_1 = "session_db"
+    session_id_2 = "session_mem"
+
+    # Simulate a session in storage with a specific session_state
+    db_state = {"db_key": "db_value", "shared_key": "db"}
+    team_storage.upsert(
+        session=type("TeamSession", (), {
+            "session_id": session_id_1,
+            "session_data": {
+                "session_state": db_state.copy(),
+                "session_name": "db_session"
+            },
+            "team_session_id": str(uuid.uuid4()),
+            "team_id": str(uuid.uuid4()),
+            "user_id": None,
+            "team_data": None,
+            "extra_data": None,
+        })()
+    )
+
+    # Set agent's in-memory session_state to something different
+    route_team.session_state = {"mem_key": "mem_value", "shared_key": "mem"}
+    route_team.session_id = session_id_2
+    route_team.session_name = "mem_session"
+
+    # Run with the in-memory session (should use in-memory state)
+    route_team.run("Test in-memory", session_id=session_id_2)
+    assert route_team.session_state == {"current_session_id": session_id_2, "mem_key": "mem_value", "shared_key": "mem"}
+    assert route_team.session_name == "mem_session"
+
+    # Now switch to the DB session (should load and take precedence)
+    route_team.run("Test DB", session_id=session_id_1)
+    # The session_state should now match the DB's, not the in-memory one
+    expected_state = {"current_session_id": session_id_1, **db_state}
+    assert route_team.session_state == expected_state
+    assert route_team.session_name == "db_session"
+
+    # If we switch back to the in-memory session, it should restore the old state
+    route_team.run("Test in-memory again", session_id=session_id_2)
+    assert route_team.session_state == {"current_session_id": session_id_2, "mem_key": "mem_value", "shared_key": "mem"}
+    assert route_team.session_name == "mem_session"