From 5fb6e0e74d687ae23e880706c3b44b98eeec6cca Mon Sep 17 00:00:00 2001
From: Mohamed Boudra <boudra.moha@gmail.com>
Date: Sat, 9 May 2026 20:46:20 +0700
Subject: [PATCH] test: defang two flaky tests on main CI
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

agent.integration "creates an autonomous live turn" — the prompt asked
Claude to use a `Task` tool that doesn't exist in the SDK (Paseo
synthesizes Task entries from sidechain notifications, but Claude can't
invoke it). Haiku non-deterministically refused or complied. Switch to
Bash with run_in_background, matching the deterministic
claude-autonomous-wake-simple.real.e2e variant — same autonomous-wake
mechanism is exercised.

schedule/service "defaults new-agent modeId to provider's unattended
mode" — afterEach raced AgentStorage's background snapshot persist,
producing intermittent ENOTEMPTY rmdirs. Drain pending writes with
agentStorage.flush() before rm.
---
 .../server/agent/providers/claude/agent.integration.test.ts | 6 +++---
 packages/server/src/server/schedule/service.test.ts         | 3 +++
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/packages/server/src/server/agent/providers/claude/agent.integration.test.ts b/packages/server/src/server/agent/providers/claude/agent.integration.test.ts
index 8402b282c..3e39c9ba9 100644
--- a/packages/server/src/server/agent/providers/claude/agent.integration.test.ts
+++ b/packages/server/src/server/agent/providers/claude/agent.integration.test.ts
@@ -378,9 +378,9 @@ describe("ClaudeAgentSession integration", () => {
         streamSession(
           handle.session,
           [
-            "Use the Task tool to start a background sub-agent.",
-            "In that task, run the Bash command exactly: sleep 3 && echo BACKGROUND_DONE",
-            "Do not wait for task completion.",
+            "Use the Bash tool with run_in_background.",
+            "Run exactly: sleep 3",
+            "Do not wait for the task result.",
             "Reply immediately with exactly: SPAWNED",
             `When the background task completes later, reply with exactly: ${autonomousWakeToken}`,
           ].join(" "),
diff --git a/packages/server/src/server/schedule/service.test.ts b/packages/server/src/server/schedule/service.test.ts
index 3b39b3089..4bfa62404 100644
--- a/packages/server/src/server/schedule/service.test.ts
+++ b/packages/server/src/server/schedule/service.test.ts
@@ -27,6 +27,9 @@ describe("ScheduleService", () => {
   });
 
   afterEach(async () => {
+    // Drain pending background persists before deleting the dir to avoid
+    // ENOTEMPTY races when AgentManager flushes a snapshot mid-cleanup.
+    await agentStorage.flush();
     await rm(tempDir, { recursive: true, force: true });
   });