From 5aa517863a810010984f9c25a8acfd63f6322e65 Mon Sep 17 00:00:00 2001
From: Julius Marminge <julius0216@outlook.com>
Date: Thu, 26 Feb 2026 17:49:51 -0800
Subject: [PATCH] Use Effect.sleep in orchestration integration tests

- replace custom Promise-based sleep helpers with `Effect.sleep`
- remove now-unused integration sleep error class and harness error mapping
---
 .../OrchestrationEngineHarness.integration.ts       |  6 +-----
 .../orchestrationEngine.integration.test.ts         | 13 +------------
 2 files changed, 2 insertions(+), 17 deletions(-)

diff --git a/apps/server/integration/OrchestrationEngineHarness.integration.ts b/apps/server/integration/OrchestrationEngineHarness.integration.ts
index 696e24f036b60f0e032b684d6daab0e70a11b97e..dc28864c13748c8d9af4ec7e5b9d5c7fe37d1adf 100644
--- a/apps/server/integration/OrchestrationEngineHarness.integration.ts
+++ b/apps/server/integration/OrchestrationEngineHarness.integration.ts
@@ -170,11 +170,7 @@ export interface OrchestrationIntegrationHarness {
 }
 
 export const makeOrchestrationIntegrationHarness = Effect.gen(function* () {
-  const sleep = (ms: number) =>
-    Effect.tryPromise({
-      try: () => new Promise<void>((resolve) => setTimeout(resolve, ms)),
-      catch: (cause) => new OrchestrationHarnessRuntimeError({ operation: "sleep", cause }),
-    }).pipe(Effect.orDie);
+  const sleep = (ms: number) => Effect.sleep(ms);
   const adapterHarness = yield* makeTestProviderAdapterHarness;
 
   const rootDir = fs.mkdtempSync(path.join(os.tmpdir(), "t3-orchestration-integration-"));
diff --git a/apps/server/integration/orchestrationEngine.integration.test.ts b/apps/server/integration/orchestrationEngine.integration.test.ts
index 91afa283ee44bdc2f36a91d29ea1467361994634..817a5895a33530d662896ccfe6e38f47ca2a4b81 100644
--- a/apps/server/integration/orchestrationEngine.integration.test.ts
+++ b/apps/server/integration/orchestrationEngine.integration.test.ts
@@ -45,13 +45,6 @@ function nowIso() {
   return new Date().toISOString();
 }
 
-class IntegrationSleepError extends Schema.TaggedErrorClass<IntegrationSleepError>()(
-  "IntegrationSleepError",
-  {
-    cause: Schema.optional(Schema.Defect),
-  },
-) {}
-
 class IntegrationWaitTimeoutError extends Schema.TaggedErrorClass<IntegrationWaitTimeoutError>()(
   "IntegrationWaitTimeoutError",
   {
@@ -59,11 +52,7 @@ class IntegrationWaitTimeoutError extends Schema.TaggedErrorClass<IntegrationWai
   },
 ) {}
 
-const sleep = (ms: number) =>
-  Effect.tryPromise({
-    try: () => new Promise<void>((resolve) => setTimeout(resolve, ms)),
-    catch: (cause) => new IntegrationSleepError({ cause }),
-  }).pipe(Effect.orDie);
+const sleep = (ms: number) => Effect.sleep(ms);
 
 function waitForSync<A>(
   read: () => A,
-- 
2.54.0