@@ -19,6 +19,7 @@ import type {
1919import { waitForWorkflowStatus } from "./utils/waitForWorkflowStatus" ;
2020import { executeWorkflowWithRetry } from "./utils/executeWorkflowWithRetry" ;
2121import { createClientWithRetry } from "./utils/createClientWithRetry" ;
22+ import { describeForOrkesV5 } from "./utils/customJestDescribe" ;
2223
2324describe ( "SDK Worker Registration" , ( ) => {
2425 const clientPromise = createClientWithRetry ( ) ;
@@ -63,6 +64,8 @@ describe("SDK Worker Registration", () => {
6364 expect ( registeredWorkers [ 0 ] ?. taskDefName ) . toBe ( taskName ) ;
6465 } ) ;
6566
67+ // These tests run workflows and have workers report task results; they need POST /api/tasks/update-v2 (v5 only).
68+ describeForOrkesV5 ( "Worker execution (requires update-v2)" , ( ) => {
6669 test ( "TaskHandler auto-discovers and executes decorated workers" , async ( ) => {
6770 const client = await clientPromise ;
6871 const taskName = `sdk_test_auto_discover_${ Date . now ( ) } ` ;
@@ -238,6 +241,7 @@ describe("SDK Worker Registration", () => {
238241
239242 await handler . stopWorkers ( ) ;
240243 } , 90000 ) ;
244+ } ) ;
241245
242246 test ( "worker with domain isolation" , async ( ) => {
243247 const client = await clientPromise ;
@@ -274,6 +278,7 @@ describe("SDK Worker Registration", () => {
274278 expect ( handler . running ) . toBe ( false ) ;
275279 } ) ;
276280
281+ describeForOrkesV5 ( "Worker execution (requires update-v2)" , ( ) => {
277282 test ( "NonRetryableException marks task as terminal failure" , async ( ) => {
278283 const client = await clientPromise ;
279284 const taskName = `sdk_test_non_retryable_${ Date . now ( ) } ` ;
@@ -523,6 +528,7 @@ describe("SDK Worker Registration", () => {
523528
524529 await handler . stopWorkers ( ) ;
525530 } , 90000 ) ;
531+ } ) ;
526532
527533 test ( "TaskHandler lifecycle - start and stop multiple times" , async ( ) => {
528534 const client = await clientPromise ;
0 commit comments