Progress updates from an OpenAI Agents SDK agent

from agents import Agent, ItemHelpers, Runner
from openai.types.responses import ResponseTextDeltaEvent

result = Runner.run_streamed(agent, "Upgrade the payments service to the new API")
async for event in result.stream_events():
    if event.type == "raw_response_event" and isinstance(event.data, ResponseTextDeltaEvent):
        print(event.data.delta, end="", flush=True)
    elif event.type == "run_item_stream_event":
        if event.item.type == "tool_call_item":
            print("\n> tool called")
        elif event.item.type == "tool_call_output_item":
            print("> tool finished")
        elif event.item.type == "message_output_item":
            print(ItemHelpers.text_message_output(event.item))
    elif event.type == "agent_updated_stream_event":
        print(f"> now running: {event.new_agent.name}")

import os
from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp

WORKFLOW = """You share a task list with the person through the taskhold tools. They watch a live board.
- Start: taskhold_begin with title, project "payments", a short list of steps and agent "Upgrade agent (Agents SDK)".
- Each step done: taskhold_complete on the step with start_next: true.
- Long step: taskhold_progress on the step with current, total and a short message. Every few minutes at most.
- Need a decision: taskhold_block with one question, then taskhold_updates with task_id, since and wait: 50 until the reply arrives.
- Done: taskhold_complete on the task with what changed and how you checked it."""

async with MCPServerStreamableHttp(
    name="taskhold",
    params={
        "url": "https://taskhold.com/api/mcp",
        "headers": {"Authorization": f"Bearer {os.environ['TASKHOLD_API_KEY']}"},
        "timeout": 60,
    },
    cache_tools_list=True,
) as taskhold:
    agent = Agent(name="Upgrade agent", instructions=WORKFLOW, mcp_servers=[taskhold])
    result = await Runner.run(agent, "Upgrade the payments service to the new API")