6e95517659
* Python: Split type checkers by target (pyright source, 5 checkers on tests/samples) Rework the typing setup along the lines of the 'too many type checkers' approach: - Pyright (strict) is now the sole source-code type checker; mypy is removed from source and its [tool.mypy] block becomes a relaxed profile used only for tests/samples. - Tests are checked by all five checkers (pyright relaxed, mypy, pyrefly, ty, zuban); samples by pyright, pyrefly, and ty. All run in a relaxed/ basic profile so authors aren't forced into over-annotation. - Add pyrightconfig.tests.json and bump sample pyright configs to basic. - Unify test/sample typing onto the same parallel fan-out used by source pyright via run_command_items in task_runner.py. - Make version-conditional imports symmetric: keep or drop the '# type: ignore' on both branches so results match across interpreter versions (local vs CI). - Update SKILL.md, DEV_SETUP.md, and CODING_STANDARD.md for the five gating checkers and pyright on source+tests+samples. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Python: Fix merge regressions from main (typing + runtime) Merging main into the type-checker split branch surfaced regressions that the new five-checker test suite and unit tests caught: Runtime fixes: - anthropic: restore the dropped `cache_read_input_token_count` mapping in _parse_usage_from_anthropic (lost during merge conflict resolution). - gemini: _get_function_calling_mode test helper returned str(enum) ('FunctionCallingConfigMode.AUTO') instead of the enum value ('AUTO'). - openai: _response_id_from_token test helper was an infinite self-recursion; return token['response_id']. - orchestrations: reset output_events per approval iteration so the terminal output assertion counts only the final run. - core: drop a stale duplicate harness test whose message ('non-negative') contradicted the source ('positive'). - purview: import PolicyLocation/PolicyScope/ProtectionScopeActivities/ ExecutionMode used by the processor tests. Type-checker fixes (tests, relaxed profile): - core: pyright/mypy/pyrefly/ty/zuban green-ups across the harness, MCP, observability and types tests. - anthropic/openai: route provider-namespaced UsageDetails keys through a dict cast (extra_items TypedDict unsupported by mypy/ty). - purview: typed model constructors and cache-mock casts. - ag-ui: annotate WorkflowContext[Any, Any] so yield_output accepts test payloads, guard Optional forwarded_props, and ty-ignore intentional bad args. Source pyright (sole source checker) flagged unnecessary ignores newly introduced by merged code in core _tools.py and declarative _declarative_base.py. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Python: Isolate per-package mypy cache in test-typing fan-out The parallel test-typing fan-out runs many mypy processes concurrently, all defaulting to a single shared ./.mypy_cache. Concurrent writes corrupt the cache and mypy aborts with INTERNAL ERROR (intermittently, depending on worker timing) -- which is why CI's Test Typing job failed on a shifting set of packages while a single-package run was fine. Give each mypy invocation an isolated cache dir keyed by its target paths so incremental caching still works per package without races. Other checkers (zuban/pyrefly/ty/pyright) maintain their own caches and are unaffected. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Python: Make lab pyright-only on source (drop source mypy) Lab was the last package still running mypy on its source code, requiring mypy-only `# type: ignore` comments that pyright (the sole source checker everywhere else) flags as unnecessary. Align lab with the rest of the monorepo: - Remove the lab source mypy poe tasks (mypy-gaia/lightning/tau2) and the now-dead strict [tool.mypy] config block. - Drop the 'Run lab mypy' CI step; lab source is type-checked by pyright only. Lab tests remain covered by the workspace test-typing fan-out (mypy, pyrefly, ty, zuban, pyright over tests using the relaxed root config). Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Python: Fix test-typing regressions from latest main merge A fresh merge from main brought in new test code never run under the five-checker test-typing suite. Green up across the affected packages: - core: narrow Optional span.attributes with 'and' guards in span filters and assert+cast the json.loads(...attributes[...]) reads (test_observability); match the existing as_agent ignore on the protocol-typed fixture (test_clients). - openai: align new streaming tests with the established chat_options dict pattern (ChatOptions TypedDict isn't assignable to dict), route Optional .annotations[0] access through a small _first_annotation helper (mirrors the file's assert-not-None convention), and annotate a mapped ResponseStream. - foundry_hosting: annotate error: dict[str, Any] = body.get(...) or {} (zuban needs the annotation). - foundry: narrow ignores for the live AIProjectClient credential arg (pyrefly) and connections.get_default (zuban) SDK type gaps. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * updated pyright version * pyright fix * Python: Fix source typing for pyright 1.1.410 Pyright 1.1.410 tightened several checks. Apply the same source fixes as upstream PR #6275: - anthropic: import AsyncAnthropicBedrock from anthropic.lib.bedrock and AsyncAnthropicVertex from anthropic.lib.vertex (no longer re-exported from the anthropic top-level package -> reportPrivateImportUsage). - core _types.py: cast the transform-hook result to UpdateT (reportAssignmentType). - core _workflows/_events.py: annotate the @contextmanager helper as Generator[None] instead of Iterator[None] (reportDeprecated). - redis: build the combined filter expression with an explicit loop instead of reduce(and_, ...), which pyright could no longer fully type (drops the now unused functools.reduce / operator.and_ imports). Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> * Python: Accept plain-text body in Azure Functions workflow/run endpoint The workflow_orchestrator already accepts plain strings as well as JSON objects via context.get_input(), but the start_workflow_orchestration HTTP handler only accepted JSON and returned 400 for any non-JSON body. This made the functions integration tests that POST text/plain to /api/workflow/run (e.g. test_09_workflow_shared_state) fail consistently with 400 != 202. Fall back to the raw request body (decoded as UTF-8) when the body is not JSON, rejecting only a truly empty body. The JSON path is unchanged. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --------- Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
153 lines
7.0 KiB
Python
153 lines
7.0 KiB
Python
# Copyright (c) Microsoft. All rights reserved.
|
|
|
|
import asyncio
|
|
import os
|
|
from random import randint
|
|
from typing import Annotated
|
|
|
|
from agent_framework import Agent, tool
|
|
from agent_framework.foundry import FoundryAgent, FoundryChatClient, to_prompt_agent
|
|
from azure.ai.projects.aio import AIProjectClient
|
|
from azure.identity.aio import AzureCliCredential
|
|
from dotenv import load_dotenv
|
|
from pydantic import Field
|
|
|
|
load_dotenv()
|
|
|
|
"""
|
|
Foundry Prompt Agent: Convert, Publish, Connect, and Run
|
|
|
|
This sample shows the end-to-end loop:
|
|
|
|
1. Build an ``Agent`` backed by ``FoundryChatClient`` with a local ``@tool``
|
|
function and Foundry-hosted tools.
|
|
2. Run the local ``Agent`` directly against the Foundry Responses API.
|
|
3. Convert it with ``to_prompt_agent(agent)`` and publish via
|
|
``AIProjectClient.agents.create_version(...)``.
|
|
4. Connect to the deployed prompt agent with ``FoundryAgent`` and pass the
|
|
*same* ``book_hotel`` callable through ``tools=`` so the server-side prompt
|
|
agent and the client share a single tool definition.
|
|
|
|
The Foundry prompt agent only receives the ``book_hotel`` *declaration* (its
|
|
JSON schema). When the deployed agent decides to call the tool, ``FoundryAgent``
|
|
executes the local Python implementation by matching tool names — keeping the
|
|
schema on the server and the implementation on the client in sync.
|
|
|
|
Local ``Agent`` vs deployed prompt agent — compare & contrast when calling
|
|
``run`` on each:
|
|
|
|
* **Runtime / latency.** ``Agent.run`` issues a single ``responses.create``
|
|
call against the Foundry Responses API. ``FoundryAgent.run`` against a
|
|
published prompt agent goes through the Foundry Agents service, which
|
|
resolves the stored ``PromptAgentDefinition`` (instructions, tools,
|
|
generation parameters, RAI config) on every call before forwarding to the
|
|
model. Expect a small per-call overhead on the deployed path in exchange
|
|
for centrally managed configuration.
|
|
* **Configurability.** With the local ``Agent``, model, instructions, tools,
|
|
``default_options``, etc. live in your process — change them, restart, and
|
|
the next ``run`` picks them up. With the deployed prompt agent, those same
|
|
fields are versioned server-side: publishing a new version updates every
|
|
consumer at once and you keep an audit trail of previous versions, but you
|
|
must call ``create_version`` (or pin ``agent_version``) to roll changes
|
|
out or back.
|
|
* **Persistence / sharing.** A local ``Agent`` instance only exists for the
|
|
lifetime of the process that created it; tools and instructions are not
|
|
discoverable by anything else. A published prompt agent is a first-class
|
|
Foundry resource — other services, other languages, and the Foundry portal
|
|
can all bind to it by ``agent_name`` (+ optional ``agent_version``) and get
|
|
the same behaviour. Local ``@tool`` callables stay on the client; only
|
|
their JSON schema is persisted, so the implementation must be supplied
|
|
again at connection time via ``FoundryAgent(tools=[...])``.
|
|
|
|
``to_prompt_agent`` is experimental
|
|
(``ExperimentalFeature.TO_PROMPT_AGENT``) and may change before being released.
|
|
"""
|
|
|
|
|
|
@tool
|
|
def book_hotel(
|
|
city: Annotated[str, Field(description="The city to book the hotel in.")],
|
|
nights: Annotated[int, Field(description="Number of nights to stay.")],
|
|
) -> str:
|
|
"""Book a hotel room for the given city and number of nights."""
|
|
return f"Booked a hotel in {city} for {nights} nights. Confirmation #CTX-{randint(1000, 9999)}."
|
|
|
|
|
|
async def main() -> None:
|
|
print("=== Foundry Prompt Agent: Convert, Publish, Connect, and Run ===\n")
|
|
|
|
project_endpoint = os.environ["FOUNDRY_PROJECT_ENDPOINT"]
|
|
model = os.environ["FOUNDRY_MODEL"]
|
|
|
|
# Use ``async with`` so the credential and project client are closed even if the
|
|
# body below raises. The ``try/finally`` around ``delete`` further guarantees we
|
|
# don't leave an orphaned prompt agent in the Foundry project after a failure.
|
|
async with (
|
|
AzureCliCredential() as credential,
|
|
AIProjectClient(endpoint=project_endpoint, credential=credential) as project_client,
|
|
):
|
|
# 1) Define the Agent. `name` / `description` set here become the Foundry agent identity
|
|
# on publish; `book_hotel` is the local implementation that backs the published declaration.
|
|
agent = Agent(
|
|
client=FoundryChatClient(
|
|
project_endpoint=project_endpoint,
|
|
model=model,
|
|
credential=credential,
|
|
),
|
|
name="travel-agent",
|
|
description="Helps Contoso employees book travel.",
|
|
instructions="You are a helpful travel assistant. Use the booking tool when asked.",
|
|
tools=[
|
|
FoundryChatClient.get_web_search_tool(),
|
|
book_hotel,
|
|
],
|
|
default_options={"reasoning": {"effort": "medium"}},
|
|
)
|
|
|
|
query = "Book me a hotel in Seattle for 3 nights."
|
|
|
|
# 2) Run the local Agent. This calls the Foundry Responses API directly — instructions,
|
|
# tools, and generation parameters live in this process only.
|
|
print(f"User (local Agent): {query}")
|
|
local_result = await agent.run(query)
|
|
print(f"Local Agent: {local_result}\n")
|
|
|
|
# 3) Convert and publish. The version returned by Foundry includes the version label
|
|
# we need when connecting back to that specific deployment.
|
|
if agent.name is None:
|
|
raise ValueError("Agent name is required to create a prompt agent version.")
|
|
created = await project_client.agents.create_version(
|
|
agent_name=agent.name,
|
|
# note this line:
|
|
definition=to_prompt_agent(agent),
|
|
description=agent.description,
|
|
)
|
|
print(f"Published prompt agent: {created.name} v{created.version}\n")
|
|
|
|
try:
|
|
# 4) Connect to the deployed prompt agent with FoundryAgent and pass the *same* callable
|
|
# tool. FoundryAgent runs the local function when the server-side agent invokes the tool,
|
|
# matching by name. Compared to step 2, instructions/tools/generation parameters now
|
|
# come from the stored PromptAgentDefinition rather than this process.
|
|
deployed = FoundryAgent(
|
|
project_endpoint=project_endpoint,
|
|
agent_name=created.name,
|
|
agent_version=created.version,
|
|
credential=credential,
|
|
tools=[book_hotel],
|
|
)
|
|
|
|
print(f"User (deployed agent): {query}")
|
|
deployed_result = await deployed.run(query)
|
|
print(f"Deployed Agent: {deployed_result}")
|
|
finally:
|
|
# 5) Cleanup: delete the deployed prompt agent (and all its versions) even if step 4
|
|
# raised, so re-running the sample stays idempotent and we don't leak resources in
|
|
# the Foundry project.
|
|
await project_client.agents.delete(agent_name=created.name)
|
|
print(f"\nDeleted prompt agent {created.name!r} and all its versions.")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|