diff --git a/apps/cli/src/index.tsx b/apps/cli/src/index.tsx index c594600e..2742423c 100644 --- a/apps/cli/src/index.tsx +++ b/apps/cli/src/index.tsx @@ -234,11 +234,6 @@ const App: React.FC = () => { }; await client.runs.create(threadId, MANAGER_GRAPH_ID, { input: interruptInput, - metadata: { - source: "cli:resume_interrupt", - owner, - repo: repoName, - }, config: { recursion_limit: 400, }, diff --git a/apps/cli/src/streaming.ts b/apps/cli/src/streaming.ts index 6bcc79fa..9cbdc628 100644 --- a/apps/cli/src/streaming.ts +++ b/apps/cli/src/streaming.ts @@ -255,11 +255,6 @@ export class StreamingService { const run = await newClient.runs.create(threadId, MANAGER_GRAPH_ID, { input: runInput, - metadata: { - source: "cli:start_manager", - owner: runInput.targetRepository?.owner, - repo: runInput.targetRepository?.repo, - }, config: { recursion_limit: 400, }, diff --git a/apps/open-swe/src/graphs/manager/nodes/classify-message/index.ts b/apps/open-swe/src/graphs/manager/nodes/classify-message/index.ts index 7e307724..200ac96a 100644 --- a/apps/open-swe/src/graphs/manager/nodes/classify-message/index.ts +++ b/apps/open-swe/src/graphs/manager/nodes/classify-message/index.ts @@ -300,11 +300,6 @@ export async function classifyMessage( command: { resume: plannerResume, }, - metadata: { - source: "manager:classify_message_resume_planner", - owner: state.targetRepository?.owner, - repo: state.targetRepository?.repo, - }, streamMode: OPEN_SWE_STREAM_MODE as StreamMode[], }, ); diff --git a/apps/open-swe/src/graphs/manager/nodes/create-new-session.ts b/apps/open-swe/src/graphs/manager/nodes/create-new-session.ts index fac5b815..dbe234f0 100644 --- a/apps/open-swe/src/graphs/manager/nodes/create-new-session.ts +++ b/apps/open-swe/src/graphs/manager/nodes/create-new-session.ts @@ -90,11 +90,6 @@ ${ISSUE_CONTENT_CLOSE_TAG}`, update: commandUpdate, goto: "start-planner", }, - metadata: { - source: "manager:create_new_session", - owner: state.targetRepository?.owner, - repo: state.targetRepository?.repo, - }, config: { recursion_limit: 400, configurable: getCustomConfigurableFields(config), diff --git a/apps/open-swe/src/graphs/manager/nodes/start-planner.ts b/apps/open-swe/src/graphs/manager/nodes/start-planner.ts index bd15ff49..80f521b2 100644 --- a/apps/open-swe/src/graphs/manager/nodes/start-planner.ts +++ b/apps/open-swe/src/graphs/manager/nodes/start-planner.ts @@ -63,11 +63,6 @@ export async function startPlanner( PLANNER_GRAPH_ID, { input: runInput, - metadata: { - source: "manager:start_planner", - owner: state.targetRepository?.owner, - repo: state.targetRepository?.repo, - }, config: { recursion_limit: 400, configurable: getCustomConfigurableFields(config), diff --git a/apps/open-swe/src/graphs/planner/nodes/proposed-plan.ts b/apps/open-swe/src/graphs/planner/nodes/proposed-plan.ts index 08325945..d124cbda 100644 --- a/apps/open-swe/src/graphs/planner/nodes/proposed-plan.ts +++ b/apps/open-swe/src/graphs/planner/nodes/proposed-plan.ts @@ -114,11 +114,6 @@ async function startProgrammerRun(input: { PROGRAMMER_GRAPH_ID, { input: runInput, - metadata: { - source: "planner:proposed_plan", - owner: state.targetRepository?.owner, - repo: state.targetRepository?.repo, - }, config: { recursion_limit: 400, configurable: getCustomConfigurableFields(config), diff --git a/apps/open-swe/src/routes/github/issue-webhook.ts b/apps/open-swe/src/routes/github/issue-webhook.ts index 938ebc49..098ff857 100644 --- a/apps/open-swe/src/routes/github/issue-webhook.ts +++ b/apps/open-swe/src/routes/github/issue-webhook.ts @@ -190,11 +190,6 @@ webhooks.on("issues.labeled", async ({ payload }) => { const run = await langGraphClient.runs.create(threadId, MANAGER_GRAPH_ID, { input: runInput, config, - metadata: { - source: "github_webhook:issue_label", - owner: issueData.owner, - repo: issueData.repo, - }, ifNotExists: "create", streamResumable: true, streamMode: OPEN_SWE_STREAM_MODE as StreamMode[], diff --git a/apps/web/src/components/thread/messages/ai.tsx b/apps/web/src/components/thread/messages/ai.tsx index 68f587b0..439705a3 100644 --- a/apps/web/src/components/thread/messages/ai.tsx +++ b/apps/web/src/components/thread/messages/ai.tsx @@ -1,19 +1,16 @@ import { parsePartialJson } from "@langchain/core/output_parsers"; import { AIMessage, - Checkpoint, Message, StreamMode, ToolMessage, } from "@langchain/langgraph-sdk"; import { getContentString } from "../utils"; -import { BranchSwitcher, CommandBar } from "./shared"; import { MarkdownText } from "../markdown-text"; import { LoadExternalComponent, UIMessage, } from "@langchain/langgraph-sdk/react-ui"; -import { cn } from "@/lib/utils"; import { ToolCalls, ToolResult } from "./tool-calls"; import { MessageContentComplex } from "@langchain/core/messages"; import { Fragment } from "react/jsx-runtime"; @@ -345,19 +342,6 @@ export function mapToolMessageToActionStepProps( }; } -const attemptParseOwnerRepo = (repoQueryParam: string) => { - try { - if (!repoQueryParam || !repoQueryParam.includes("/")) { - return undefined; - } - const [owner, repo] = repoQueryParam.split("/"); - return { owner, repo }; - } catch { - // no-op - return undefined; - } -}; - export function AssistantMessage({ message, threadId, @@ -377,7 +361,6 @@ export function AssistantMessage({ modifyRunId?: (runId: string) => Promise; requestHelpEvents?: CustomNodeEvent[]; }) { - const [repo] = useQueryState("repo"); const content = message?.content ?? []; const handleHumanHelpResponse = async (response: string) => { @@ -388,15 +371,8 @@ export function AssistantMessage({ }, ]; - const ownerRepo = attemptParseOwnerRepo(repo ?? ""); - const newRun = await thread.client.runs.create(threadId, assistantId, { command: { resume: humanResponse }, - metadata: { - source: "web:interrupt_response", - owner: ownerRepo?.owner, - repo: ownerRepo?.repo, - }, config: { recursion_limit: 400, }, diff --git a/apps/web/src/components/v2/terminal-input.tsx b/apps/web/src/components/v2/terminal-input.tsx index 74cf935f..ec20077c 100644 --- a/apps/web/src/components/v2/terminal-input.tsx +++ b/apps/web/src/components/v2/terminal-input.tsx @@ -96,11 +96,6 @@ export function TerminalInput({ MANAGER_GRAPH_ID, { input: runInput, - metadata: { - source: "web:start_manager", - owner: selectedRepository.owner, - repo: selectedRepository.repo, - }, config: { recursion_limit: 400, configurable: {