- Update new tests to be v5 only

- Try cloning fetch to prevent 502/503

Author: ajlai-orkes

src/integration-tests/E2EFiveTaskWorkflow.test.ts

@@ -1,7 +1,6 @@
 import {
   afterEach,
   beforeAll,
-  describe,
   expect,
   jest,
   test,
@@ -18,8 +17,9 @@ import {
 } from "../sdk";
 import { cleanupWorkflowsAndTasks } from "./utils/cleanup";
 import { waitForWorkflowStatus } from "./utils/waitForWorkflowStatus";
+import { describeForOrkesV5 } from "./utils/customJestDescribe";
 
-describe("E2E: 5-task workflow × 50 executions", () => {
+describeForOrkesV5("E2E: 5-task workflow × 50 executions", () => {
   const clientPromise: Promise<Client> = orkesConductorClient();
   let executor: WorkflowExecutor;
   let handler: TaskHandler | undefined;

src/integration-tests/PromptClient.test.ts

@@ -5,14 +5,15 @@ import {
   PromptClient,
 } from "../sdk";
 import type { Tag } from "../open-api";
+import { describeForOrkesV5 } from "./utils/customJestDescribe";
 
 /**
- * E2E Integration Tests for PromptClient
+ * E2E Integration Tests for PromptClient (v5 only).
  *
  * Tests prompt CRUD, tag management, and (optionally) prompt testing
  * against a configured LLM integration.
  */
-describe("PromptClient", () => {
+describeForOrkesV5("PromptClient", () => {
   jest.setTimeout(60000);
 
   const clientPromise = orkesConductorClient();

src/integration-tests/WorkerAdvanced.test.ts

@@ -24,17 +24,18 @@ import {
 import { cleanupWorkflowsAndTasks } from "./utils/cleanup";
 import { waitForWorkflowStatus } from "./utils/waitForWorkflowStatus";
 import { executeWorkflowWithRetry } from "./utils/executeWorkflowWithRetry";
+import { describeForOrkesV5 } from "./utils/customJestDescribe";
 
 /**
- * E2E Integration Tests for Advanced Worker Features
+ * E2E Integration Tests for Advanced Worker Features (v5 only).
  *
  * Tests features not covered in WorkerRegistration.test.ts:
  * - MetricsCollector — verify metrics collected during workflow execution
  * - MetricsServer — start on port, scrape /metrics and /health
  * - TaskContext — getTaskContext(), addLog(), verify logs via getTaskLogs()
  * - Worker with paused option
  */
-describe("Worker Advanced Features", () => {
+describeForOrkesV5("Worker Advanced Features", () => {
   jest.setTimeout(120000);
 
   const clientPromise = orkesConductorClient();

src/sdk/createConductorClient/helpers/fetchWithRetry.ts

@@ -129,13 +129,19 @@ export const retryFetch = async (
   const getInit = (): Init =>
     requestTimeoutMs ? applyTimeout(init, requestTimeoutMs) : init ?? {};
 
+  /** Fresh request per attempt — reusing a Request whose body was already consumed causes "body disturbed or locked" on retry (e.g. 502/503/504 in CI). */
+  const getRequest = (): Input =>
+    typeof input === "object" && input !== null && "clone" in input && typeof (input as Request).clone === "function"
+      ? (input as Request).clone()
+      : input;
+
   let lastError: unknown;
 
   // Transport retry loop
   for (let transportAttempt = 0; transportAttempt <= maxTransportRetries; transportAttempt++) {
     let response: Response;
     try {
-      response = cloneResponse(await fetchFn(input, getInit()));
+      response = cloneResponse(await fetchFn(getRequest(), getInit()));
     } catch (error) {
       // Timeout/abort errors should NOT be retried
       if (isTimeoutError(error)) {
@@ -158,7 +164,7 @@ export const retryFetch = async (
       await new Promise((resolve) =>
         setTimeout(resolve, withJitter(initialRetryDelay * (gwAttempt + 1)))
       );
-      response = cloneResponse(await fetchFn(input, getInit()));
+      response = cloneResponse(await fetchFn(getRequest(), getInit()));
     }
 
     // Rate limit retry (429)
@@ -167,7 +173,7 @@ export const retryFetch = async (
       let delay = initialRetryDelay;
       for (let rlAttempt = 0; rlAttempt < maxRateLimitRetries; rlAttempt++) {
         await new Promise((resolve) => setTimeout(resolve, withJitter(delay)));
-        rateLimitResponse = cloneResponse(await fetchFn(input, getInit()));
+        rateLimitResponse = cloneResponse(await fetchFn(getRequest(), getInit()));
         if (rateLimitResponse.status !== 429) {
           return rateLimitResponse;
         }
@@ -191,7 +197,7 @@ export const retryFetch = async (
           headers: new Headers(init?.headers),
         };
         retryInit.headers.set("X-Authorization", newToken);
-        return cloneResponse(await fetchFn(input, retryInit));
+        return cloneResponse(await fetchFn(getRequest(), retryInit));
       }
     }