Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions python/packages/devui/agent_framework_devui/_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -375,6 +375,8 @@ async def _execute_agent(
run_kwargs: dict[str, Any] = {"stream": True}
if session:
run_kwargs["session"] = session
if request.function_invocation_kwargs is not None:
run_kwargs["function_invocation_kwargs"] = request.function_invocation_kwargs

stream = cast(Any, agent.run(user_message, **run_kwargs))
async for update in stream:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -312,6 +312,9 @@ class AgentFrameworkRequest(BaseModel):
# Reasoning parameters (for o-series models)
reasoning: dict[str, Any] | None = None # {"effort": "low" | "medium" | "high" | "minimal"}

# Agent Framework tool invocation context
function_invocation_kwargs: dict[str, Any] | None = None

# Optional extra_body for advanced use cases
extra_body: dict[str, Any] | None = None

Expand Down
27 changes: 26 additions & 1 deletion python/packages/devui/tests/devui/test_execution.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,12 +13,16 @@
import tempfile
from pathlib import Path
from typing import Any
from unittest.mock import patch

import pytest
from agent_framework import Agent, AgentExecutor, FunctionExecutor, WorkflowBuilder

# Import mock classes from conftest for direct use in some tests
from conftest import MockBaseChatClient # pyrefly: ignore[missing-import] # pyright: ignore[reportMissingImports]
from conftest import ( # pyrefly: ignore[missing-import] # pyright: ignore[reportMissingImports]
MockAgent,
MockBaseChatClient,
)

from agent_framework_devui._discovery import EntityDiscovery
from agent_framework_devui._executor import AgentFrameworkExecutor, EntityNotFoundError
Expand Down Expand Up @@ -159,6 +163,27 @@ async def test_chat_client_receives_correct_messages(executor_with_real_agent):
assert "2+2" in all_text, f"Expected '2+2' in messages, got text: '{all_text}'"


async def test_agent_execution_forwards_function_invocation_kwargs() -> None:
"""Forward request-scoped function invocation arguments to the agent."""
discovery = EntityDiscovery(None)
executor = AgentFrameworkExecutor(discovery, MessageMapper())
agent = MockAgent()
entity_info = await discovery.create_entity_info_from_object(agent, source="test")
discovery.register_entity(entity_info.id, entity_info, agent)
request = AgentFrameworkRequest(
metadata={"entity_id": entity_info.id},
input="hello",
stream=True,
function_invocation_kwargs={"tenantId": "abc123"},
)

with patch.object(agent, "run", wraps=agent.run) as run_spy:
async for _ in executor.execute_streaming(request):
pass

assert run_spy.call_args.kwargs["function_invocation_kwargs"] == {"tenantId": "abc123"}


# =============================================================================
# Workflow Execution Tests (using real WorkflowBuilder with FunctionExecutor)
# =============================================================================
Expand Down
Loading