OpenAI Agents SDK (Python) integration

.github/workflows/dojo-e2e.yml

@@ -174,6 +174,10 @@ jobs:
             test_path: tests/agUiDotnetTests
             services: ["dojo", "ag-ui-dotnet"]
             wait_on: http://localhost:9999,tcp:localhost:8023
+          - suite: openai-agents-python
+            test_path: tests/openaiAgentsPythonTests
+            services: ["dojo", "openai-agents-python"]
+            wait_on: http://localhost:9999,tcp:localhost:8024
           # - suite: vercel-ai-sdk
           #   test_path: tests/vercelAISdkTests
           #   services: ["dojo"]

.github/workflows/unit-python-sdk.yml

@@ -10,6 +10,7 @@ on:
       - "integrations/adk-middleware/python/**"
       - "integrations/aws-strands/python/**"
       - "integrations/langroid/python/**"
+      - "integrations/openai-agents/python/**"
       - "integrations/crew-ai/python/**"
       - ".github/workflows/unit-python-sdk.yml"
   pull_request:
@@ -21,6 +22,7 @@ on:
       - "integrations/adk-middleware/python/**"
       - "integrations/aws-strands/python/**"
       - "integrations/langroid/python/**"
+      - "integrations/openai-agents/python/**"
       - "integrations/crew-ai/python/**"
       - ".github/workflows/unit-python-sdk.yml"
 
@@ -336,6 +338,7 @@ jobs:
         working-directory: integrations/langroid/python
         run: uv run python -m unittest discover tests -v
 
+  openai-agents-python:
   crewai-python:
     runs-on: ubuntu-latest
 
@@ -366,6 +369,16 @@ jobs:
         id: cached-uv-dependencies
         uses: actions/cache@55cc8345863c7cc4c66a329aec7e433d2d1c52a9  # v6.1.0
         with:
+          path: integrations/openai-agents/python/.venv
+          key: ${{ steps.fork-check.outputs.prefix }}venv-${{ runner.os }}-openai-agents-python-${{ hashFiles('integrations/openai-agents/python/uv.lock') }}
+
+      - name: Install dependencies
+        working-directory: integrations/openai-agents/python
+        run: uv sync
+
+      - name: Run tests
+        working-directory: integrations/openai-agents/python
+        run: uv run pytest
           path: integrations/crew-ai/python/.venv
           key: ${{ steps.fork-check.outputs.prefix }}venv-${{ runner.os }}-crewai-${{ hashFiles('integrations/crew-ai/python/uv.lock') }}
 

.gitignore

@@ -52,3 +52,6 @@ node_modules
 
 # actionlint linter binary (dev tool, do not commit)
 /actionlint
+
+# Dev
+.playwright-mcp/

README.md

@@ -116,7 +116,7 @@ AG-UI was born from CopilotKit's initial **partnership** with LangGraph and Crew
 | ---------- | ------- | ---------------- |
 | [Claude Agent SDK](https://github.com/ag-ui-protocol/ag-ui/tree/main/integrations/claude-agent-sdk) | ✅ Supported | 🎮 [Demos](https://dojo.ag-ui.com/claude-agent-sdk-python/feature/shared_state) |
 | [Langroid](https://github.com/ag-ui-protocol/ag-ui/tree/main/integrations/langroid) | ✅ Supported | 🎮 [Demos](https://dojo.ag-ui.com/langroid/feature/shared_state) |
-| [OpenAI Agent SDK](https://openai.github.io/openai-agents-python/) | 🛠️ In Progress | – |
+| [OpenAI Agents SDK](https://openai.github.io/openai-agents-python/) | 🛠️ In Progress | – |
 | [Cloudflare Agents](https://developers.cloudflare.com/agents/) | 🛠️ In Progress | – |
 
 

apps/dojo/e2e/aimock-setup.ts

@@ -2,6 +2,7 @@ import { LLMock, type ChatMessage } from "@copilotkit/aimock";
 import * as path from "node:path";
 import { registerA2UIRecoveryFixtures } from "./a2ui-recovery-fixtures";
 import { registerA2UIADKFixtures } from "./a2ui-adk-fixtures";
+import { registerOpenAIAgentsFixtures } from "./openai-agents-fixtures";
 
 // Configurable so parallel worktrees / runs don't collide on one aimock port.
 const MOCK_PORT = Number(process.env.AIMOCK_PORT) || 5555;
@@ -31,6 +32,7 @@ export async function setupLLMock(): Promise<void> {
   // OSS-162 A2UI recovery showcase fixtures (predicate fixtures, must precede
   // the generic loadFixtureFile below).
   registerA2UIRecoveryFixtures(mockServer);
+  registerOpenAIAgentsFixtures(mockServer);
 
   // Extract text from message content — handles both string and array-of-parts
   // (Strands SDK sends content as [{type: "text", text: "..."}])
@@ -1339,6 +1341,12 @@ export async function setupLLMock(): Promise<void> {
         );
         if (hasCrewExitTool && textOf(last.content) === "Crew exited")
           return false;
+        const hasOpenAIAgentsSupervisorTools = req.tools?.some((t) =>
+          ["research_topic", "write_prose", "critique_draft"].includes(
+            t.function.name,
+          ),
+        );
+        if (hasOpenAIAgentsSupervisorTools) return false;
         return true;
       },
     },

apps/dojo/e2e/openai-agents-fixtures.ts

@@ -0,0 +1,192 @@
+import { LLMock, type ChatMessage } from "@copilotkit/aimock";
+
+function textOf(content: ChatMessage["content"] | undefined): string {
+  if (typeof content === "string") return content;
+  if (!Array.isArray(content)) return "";
+  return content
+    .filter((part) => part.type === "text" && typeof part.text === "string")
+    .map((part) => part.text)
+    .join("");
+}
+
+export function registerOpenAIAgentsFixtures(mockServer: LLMock): void {
+  const hasTool = (
+    req: { tools?: { function: { name: string } }[] },
+    name: string,
+  ) => req.tools?.some((tool) => tool.function.name === name) ?? false;
+  const messagesText = (messages: ChatMessage[]) =>
+    messages.map((message) => textOf(message.content)).join("\n");
+  const systemText = (messages: ChatMessage[]) =>
+    messages
+      .filter((message) => message.role === "system")
+      .map((message) => textOf(message.content))
+      .join("\n");
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        hasTool(req, "read_ag_ui_openai_agents_docs") &&
+        messagesText(req.messages).includes(
+          "test the OpenAI Agents integration",
+        ),
+    },
+    response: {
+      toolCalls: [
+        {
+          name: "read_ag_ui_openai_agents_docs",
+          arguments: JSON.stringify({ heading: "Testing" }),
+        },
+      ],
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        hasTool(req, "issue_refund") &&
+        messagesText(req.messages).includes("ORD-1001"),
+    },
+    response: {
+      toolCalls: [
+        {
+          name: "issue_refund",
+          arguments: JSON.stringify({ order_id: "ORD-1001" }),
+        },
+      ],
+    },
+  });
+
+  const hasSupervisorTools = (req: {
+    tools?: { function: { name: string } }[];
+  }) =>
+    ["research_topic", "write_prose", "critique_draft"].every((name) =>
+      hasTool(req, name),
+    );
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        systemText(req.messages).includes("You research a topic") &&
+        !hasSupervisorTools(req),
+    },
+    response: {
+      content:
+        "AI research facts: symbolic AI began in the 1950s; machine learning later became dominant.",
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        systemText(req.messages).includes("You turn bullet-point facts") &&
+        !hasSupervisorTools(req),
+    },
+    response: {
+      content:
+        "AI evolved from symbolic systems into modern machine learning and generative models.",
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        systemText(req.messages).includes("You review a draft") &&
+        !hasSupervisorTools(req),
+    },
+    response: {
+      content:
+        "1. Improve the opening. 2. Connect the historical eras more clearly.",
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) => {
+        if (!hasSupervisorTools(req)) return false;
+        const text = messagesText(req.messages);
+        return !text.includes("AI research facts");
+      },
+    },
+    response: {
+      toolCalls: [
+        {
+          name: "research_topic",
+          arguments: JSON.stringify({ input: "history of AI" }),
+        },
+      ],
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) => {
+        if (!hasSupervisorTools(req)) return false;
+        const text = messagesText(req.messages);
+        return (
+          text.includes("AI research facts") &&
+          !text.includes("AI evolved from symbolic systems")
+        );
+      },
+    },
+    response: {
+      toolCalls: [
+        {
+          name: "write_prose",
+          arguments: JSON.stringify({ input: "AI research facts" }),
+        },
+      ],
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) => {
+        if (!hasSupervisorTools(req)) return false;
+        const text = messagesText(req.messages);
+        return (
+          text.includes("AI evolved from symbolic systems") &&
+          !text.includes("Improve the opening")
+        );
+      },
+    },
+    response: {
+      toolCalls: [
+        {
+          name: "critique_draft",
+          arguments: JSON.stringify({
+            input:
+              "AI evolved from symbolic systems into modern machine learning and generative models.",
+          }),
+        },
+      ],
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        hasSupervisorTools(req) &&
+        messagesText(req.messages).includes("Improve the opening"),
+    },
+    response: {
+      content:
+        "Artificial intelligence grew from early symbolic programs into machine learning and today's generative systems.",
+    },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        systemText(req.messages).includes("Always reply in Arabic"),
+    },
+    response: { content: "مرحبًا! أنا أجيب باللغة العربية." },
+  });
+
+  mockServer.addFixture({
+    match: {
+      predicate: (req) =>
+        systemText(req.messages).includes("Always reply in German"),
+    },
+    response: { content: "Hallo! Ich antworte auf Deutsch." },
+  });
+}

apps/dojo/e2e/tests/openaiAgentsPythonTests/agenticChatPage.spec.ts

@@ -0,0 +1,45 @@
+import { test } from "../../test-isolation-helper";
+import { AgenticChatPage } from "../../featurePages/AgenticChatPage";
+
+test("[OpenAI Agents Python] Agentic Chat sends and receives a greeting message", async ({
+  page,
+}) => {
+  await page.goto("/openai-agents-python/feature/agentic_chat");
+  const chat = new AgenticChatPage(page);
+  await chat.openChat();
+  await chat.sendMessage("Hi");
+  await chat.assertUserMessageVisible("Hi");
+  await chat.assertAgentReplyVisible(/Hello|Hi|hey/i);
+});
+
+test("[OpenAI Agents Python] Agentic Chat retains memory of previous questions", async ({
+  page,
+}) => {
+  test.slow();
+  await page.goto("/openai-agents-python/feature/agentic_chat");
+  const chat = new AgenticChatPage(page);
+  await chat.openChat();
+  await chat.sendMessage("Hi, my name is Alex");
+  await chat.assertUserMessageVisible("Hi, my name is Alex");
+  await chat.assertAgentReplyVisible(/Hello|Hi|Alex/i);
+  await chat.sendMessage("What is my name?");
+  await chat.assertUserMessageVisible("What is my name?");
+  await chat.assertAgentReplyVisible(/Alex/i);
+});
+
+test("[OpenAI Agents Python] Agentic Chat retains user messages during a conversation", async ({
+  page,
+}) => {
+  test.slow();
+  await page.goto("/openai-agents-python/feature/agentic_chat");
+  const chat = new AgenticChatPage(page);
+  await chat.openChat();
+  await chat.sendMessage("Hey there");
+  await chat.assertAgentReplyVisible(/Hello|Hi/i);
+  await chat.sendMessage("My favorite fruit is Mango");
+  await chat.assertAgentReplyVisible(/Mango/i);
+  await chat.sendMessage("and I love listening to Kaavish");
+  await chat.assertAgentReplyVisible(/Kaavish/i);
+  await chat.sendMessage("Can you remind me what my favorite fruit is?");
+  await chat.assertAgentReplyVisible(/Mango/i);
+});

apps/dojo/e2e/tests/openaiAgentsPythonTests/backendToolRenderingPage.spec.ts

@@ -0,0 +1,12 @@
+import { expect, test } from "../../test-isolation-helper";
+
+test("[OpenAI Agents Python] Backend Tool Rendering displays a weather card", async ({
+  page,
+}) => {
+  await page.goto("/openai-agents-python/feature/backend_tool_rendering");
+
+  await page.getByRole("button", { name: "Weather in San Francisco" }).click();
+
+  await expect(page.getByTestId("weather-card").last()).toBeVisible();
+  await expect(page.getByText("Humidity").last()).toBeVisible();
+});

apps/dojo/e2e/tests/openaiAgentsPythonTests/customLifecycleEventsPage.spec.ts

@@ -0,0 +1,18 @@
+import { expect, test } from "../../test-isolation-helper";
+import { sendAndAwaitResponse } from "../../utils/copilot-actions";
+
+test("[OpenAI Agents Python] Custom Lifecycle Events keeps usage with each reply", async ({
+  page,
+}) => {
+  await page.goto("/openai-agents-python/feature/custom_lifecycle_events");
+
+  await sendAndAwaitResponse(page, "Hi");
+  await sendAndAwaitResponse(page, "Tell me one interesting fact about AI.");
+
+  const usageLabels = page.getByLabel("Run usage");
+  await expect(usageLabels).toHaveCount(2);
+  for (const usage of await usageLabels.all()) {
+    await expect(usage).toContainText(/\d+ input tokens/);
+    await expect(usage).toContainText(/\d+ output tokens/);
+  }
+});

apps/dojo/e2e/tests/openaiAgentsPythonTests/docsCopilotPage.spec.ts

@@ -0,0 +1,16 @@
+import { expect, test } from "../../test-isolation-helper";
+import { sendAndAwaitResponse } from "../../utils/copilot-actions";
+
+test("[OpenAI Agents Python] Docs Copilot reads the integration documentation", async ({
+  page,
+}) => {
+  await page.goto("/openai-agents-python/feature/ag_ui_docs_copilot");
+
+  await sendAndAwaitResponse(
+    page,
+    "How do I test the OpenAI Agents integration?",
+  );
+
+  await expect(page.getByText("AG-UI OpenAI Agents docs").last()).toBeVisible();
+  await expect(page.getByText('Read "Testing"').last()).toBeVisible();
+});