Microsoft Agent Framework (tracing)

1
import asyncio
2
import os
3
4
from agent_framework import Agent, WorkflowBuilder, WorkflowContext, executor, tool
5
from agent_framework.openai import OpenAIChatCompletionClient
6
from respan import Respan
7
from respan_instrumentation_microsoft_agent_framework import (
8
    MicrosoftAgentFrameworkInstrumentor,
9
)
10
11
respan = Respan(
12
    app_name="microsoft-agent-framework-demo",
13
    instrumentations=[MicrosoftAgentFrameworkInstrumentor(capture_content=True)],
14
)
15
16
@tool
17
def lookup_weather(city: str) -> str:
18
    return f"The weather in {city} is sunny."
19
20
async def main() -> None:
21
    client = OpenAIChatCompletionClient(
22
        api_key=os.environ["OPENAI_API_KEY"],
23
        model="gpt-4.1-nano",
24
    )
25
    agent = Agent(
26
        client=client,
27
        name="weather_agent",
28
        instructions="Use the weather tool when asked about weather.",
29
        tools=[lookup_weather],
30
    )
31
32
    @executor(id="ask_weather_agent", input=str, workflow_output=str)
33
    async def ask_weather_agent(query: str, ctx: WorkflowContext) -> None:
34
        result = await agent.run(query)
35
        await ctx.yield_output(str(result))
36
37
    workflow = WorkflowBuilder(
38
        start_executor=ask_weather_agent,
39
        output_from=[ask_weather_agent],
40
        name="weather_agent_workflow",
41
    ).build()
42
43
    events = await workflow.run("What is the weather in Seattle?")
44
    for output in events.get_outputs():
45
        print(output)
46
47
asyncio.run(main())
48
respan.flush()
49
respan.shutdown()