From fa3ed5220a28f326d443726233c37e1a7df0ced5 Mon Sep 17 00:00:00 2001 From: Peter Stone Date: Thu, 4 Jun 2026 07:40:46 +0000 Subject: executor: deduplicate worker slots and fix git command execution --- internal/executor/container_test.go | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) (limited to 'internal/executor/container_test.go') diff --git a/internal/executor/container_test.go b/internal/executor/container_test.go index dec666e..8c00a0f 100644 --- a/internal/executor/container_test.go +++ b/internal/executor/container_test.go @@ -312,7 +312,9 @@ func TestDetectUncommittedChanges_ModifiedFile(t *testing.T) { if err := os.WriteFile(dir+"/main.go", []byte("package main\n// changed"), 0644); err != nil { t.Fatal(err) } - err := detectUncommittedChanges(dir) + runner := &ContainerRunner{} + err := runner.detectUncommittedChanges(context.Background(), dir) + if err == nil { t.Fatal("expected error for modified uncommitted file, got nil") } @@ -338,7 +340,9 @@ func TestDetectUncommittedChanges_NewUntrackedSourceFile(t *testing.T) { if err := os.WriteFile(dir+"/newfile.go", []byte("package main"), 0644); err != nil { t.Fatal(err) } - err := detectUncommittedChanges(dir) + runner := &ContainerRunner{} + err := runner.detectUncommittedChanges(context.Background(), dir) + if err == nil { t.Fatal("expected error for new untracked source file, got nil") } @@ -361,7 +365,9 @@ func TestDetectUncommittedChanges_ScaffoldFilesIgnored(t *testing.T) { _ = os.WriteFile(dir+"/.claudomator-env", []byte("KEY=val"), 0600) _ = os.WriteFile(dir+"/.claudomator-instructions.txt", []byte("do stuff"), 0644) _ = os.MkdirAll(dir+"/.agent-home/.claude", 0755) - err := detectUncommittedChanges(dir) + runner := &ContainerRunner{} + err := runner.detectUncommittedChanges(context.Background(), dir) + if err != nil { t.Errorf("scaffold files should not trigger uncommitted error, got: %v", err) } @@ -385,7 +391,9 @@ func TestDetectUncommittedChanges_CleanRepo(t *testing.T) { run("git", "add", "main.go") run("git", "commit", "-m", "init") // No modifications — should pass - err := detectUncommittedChanges(dir) + runner := &ContainerRunner{} + err := runner.detectUncommittedChanges(context.Background(), dir) + if err != nil { t.Errorf("clean repo should not error, got: %v", err) } -- cgit v1.2.3