update: mods

Author: Palashio

apps/open-swe/jest.config.js

@@ -16,6 +16,6 @@ export default {
   extensionsToTreatAsEsm: [".ts"],
   setupFiles: ["dotenv/config"],
   passWithNoTests: true,
-  testTimeout: 20_000,
+  testTimeout: 7200_000,
   testMatch: ["<rootDir>/src/**/*.test.ts"],
 };

apps/open-swe/langbench/evaluator.eval.ts

@@ -158,13 +158,19 @@ async function runOpenSWEWithStreamTracking(inputs: {
       return result; // instead of skipping, we should award 0 points
     }
 
+    logger.info("✅ Successfully detected planner session", {
+      thread_id: threadId,
+      plannerSessionId: plannerSession.threadId,
+      plannerRunId: plannerSession.runId,
+    });
+
     let plannerRun;
     try {
       plannerRun = await withRetry(() =>
         lgClient.runs.join(plannerSession.threadId, plannerSession.runId),
       );
 
-      logger.info("Agent joined planner session", {
+      logger.info("✅ Successfully joined planner session", {
         plannerSession,
       });
     } catch (error) {
@@ -194,15 +200,21 @@ async function runOpenSWEWithStreamTracking(inputs: {
       return result; // instead of skipping, we should award 0 points
     }
 
-    logger.info("Agent joined programmer session", {
-      programmerSession,
+    logger.info("✅ Successfully detected programmer session", {
+      thread_id: threadId,
+      programmerSessionId: programmerSession.threadId,
+      programmerRunId: programmerSession.runId,
     });
 
     let programmerRun;
     try {
       programmerRun = await withRetry(() =>
         lgClient.runs.join(programmerSession.threadId, programmerSession.runId),
       );
+
+      logger.info("✅ Successfully joined programmer session", {
+        programmerSession,
+      });
     } catch (error) {
       logger.error("Error joining programmer run", {
         thread_id: threadId,
@@ -435,6 +447,6 @@ ls.describe(DATASET_NAME, () => {
         throw new Error(`PR processing failed: ${result.error}`);
       }
     },
-    300_000, // 5 minute timeout per PR
+    0, // No timeout - run forever
   );
 });

apps/open-swe/src/graphs/programmer/nodes/open-pr.ts

@@ -35,6 +35,10 @@ import {
   getActivePlanItems,
   getPullRequestNumberFromActiveTask,
 } from "@open-swe/shared/open-swe/tasks";
+import {
+  isLocalMode,
+  getLocalWorkingDirectory,
+} from "@open-swe/shared/open-swe/local-mode";
 import { createOpenPrToolFields } from "@open-swe/shared/open-swe/tools";
 import { trackCachePerformance } from "../../../utils/caching.js";
 import { getModelManager } from "../../../utils/llms/model-manager.js";
@@ -43,7 +47,6 @@ import {
   GitHubPullRequestList,
   GitHubPullRequestUpdate,
 } from "../../../utils/github/types.js";
-import { getRepoAbsolutePath } from "@open-swe/shared/git";
 
 const logger = createLogger(LogLevel.INFO, "Open PR");
 
@@ -114,26 +117,29 @@ export async function openPullRequest(
   let branchName = state.branchName;
   let updatedTaskPlan: TaskPlan | undefined;
 
-  const repoPath = getRepoAbsolutePath(state.targetRepository);
-  const changedFiles = await getChangedFilesStatus(repoPath, sandbox, config);
+  // Only check for changed files and commit in local mode
+  if (isLocalMode(config)) {
+    const repoPath = getLocalWorkingDirectory();
+    const changedFiles = await getChangedFilesStatus(repoPath, sandbox, config);
 
-  if (changedFiles.length > 0) {
-    logger.info(`Has ${changedFiles.length} changed files. Committing.`, {
-      changedFiles,
-    });
-    const result = await checkoutBranchAndCommit(
-      config,
-      state.targetRepository,
-      sandbox,
-      {
-        branchName,
-        githubInstallationToken,
-        taskPlan: state.taskPlan,
-        githubIssueId: state.githubIssueId,
-      },
-    );
-    branchName = result.branchName;
-    updatedTaskPlan = result.updatedTaskPlan;
+    if (changedFiles.length > 0) {
+      logger.info(`Has ${changedFiles.length} changed files. Committing.`, {
+        changedFiles,
+      });
+      const result = await checkoutBranchAndCommit(
+        config,
+        state.targetRepository,
+        sandbox,
+        {
+          branchName,
+          githubInstallationToken,
+          taskPlan: state.taskPlan,
+          githubIssueId: state.githubIssueId,
+        },
+      );
+      branchName = result.branchName;
+      updatedTaskPlan = result.updatedTaskPlan;
+    }
   }
 
   const openPrTool = createOpenPrToolFields();
@@ -197,7 +203,7 @@ export async function openPullRequest(
       title,
       body: `Fixes #${state.githubIssueId}\n\n${body}`,
       githubInstallationToken,
-      baseBranch: state.targetRepository.branch,
+      baseBranch: state.targetRepository.baseCommit ?? state.targetRepository.branch,
     });
   } else {
     // Ensure the PR is ready for review

apps/open-swe/src/utils/github/git.ts

@@ -560,6 +560,31 @@ async function performClone(
   });
 
   if (targetRepository.baseCommit) {
+    // When cloning from a baseCommit, we're in detached HEAD state
+    // Create a branch if we have a branchName
+    if (branchName) {
+      try {
+        logger.info("Creating branch from baseCommit", {
+          branch: branchName,
+          baseCommit: targetRepository.baseCommit,
+        });
+        
+        await sandbox.git.createBranch(absoluteRepoDir, branchName);
+        
+        logger.info("Successfully created branch from baseCommit", {
+          branch: branchName,
+        });
+        
+        return branchName;
+      } catch (error) {
+        logger.error("Failed to create branch from baseCommit", {
+          branchName,
+          baseCommit: targetRepository.baseCommit,
+          error,
+        });
+        throw error;
+      }
+    }
     return targetRepository.baseCommit;
   }