Skip to content

Commit ab66408

Browse files
chris-olszewskiyuandrew
authored andcommitted
add skipClientWorkerSetCheck to worker options
1 parent 0a9c2ff commit ab66408

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

packages/test/src/test-integration-workflows.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -462,6 +462,7 @@ test('Worker requests Eager Activity Dispatch if possible', async (t) => {
462462
activities: {
463463
testActivity: () => 'workflow-and-activity-worker',
464464
},
465+
skipClientWorkerSetCheck: true,
465466
});
466467
const handle = await startWorkflow(executeEagerActivity);
467468
await activityWorker.runUntil(workflowWorker.runUntil(handle.result()));
@@ -501,6 +502,7 @@ test("Worker doesn't request Eager Activity Dispatch if no activities are regist
501502
const workflowWorker = await createWorker({
502503
connection: workflowWorkerConnection,
503504
activities: {},
505+
skipClientWorkerSetCheck: true,
504506
});
505507
const handle = await startWorkflow(dontExecuteEagerActivity);
506508
const result = await activityWorker.runUntil(workflowWorker.runUntil(handle.result()));

packages/test/src/test-sinks.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -261,6 +261,7 @@ if (RUN_INTEGRATION_TESTS) {
261261
sinks,
262262
maxCachedWorkflows: 0,
263263
maxConcurrentWorkflowTaskExecutions: 2,
264+
skipClientWorkerSetCheck: true,
264265
});
265266
const client = new WorkflowClient();
266267
await worker.runUntil(client.execute(workflows.logSinkTester, { taskQueue, workflowId: uuid4() }));
@@ -307,6 +308,7 @@ if (RUN_INTEGRATION_TESTS) {
307308
...defaultOptions,
308309
taskQueue,
309310
sinks,
311+
skipClientWorkerSetCheck: true,
310312
});
311313
const workflowId = uuid4();
312314
await worker.runUntil(client.execute(workflows.logSinkTester, { taskQueue, workflowId }));
@@ -320,6 +322,7 @@ if (RUN_INTEGRATION_TESTS) {
320322
{
321323
...defaultOptions,
322324
sinks,
325+
skipClientWorkerSetCheck: true,
323326
},
324327
history,
325328
workflowId
@@ -351,6 +354,7 @@ if (RUN_INTEGRATION_TESTS) {
351354
...defaultOptions,
352355
taskQueue,
353356
sinks,
357+
skipClientWorkerSetCheck: true,
354358
});
355359
const client = new WorkflowClient();
356360
const workflowId = uuid4();
@@ -367,6 +371,7 @@ if (RUN_INTEGRATION_TESTS) {
367371
{
368372
...defaultOptions,
369373
sinks,
374+
skipClientWorkerSetCheck: true,
370375
},
371376
history,
372377
workflowId
@@ -411,6 +416,7 @@ if (RUN_INTEGRATION_TESTS) {
411416
...defaultOptions,
412417
taskQueue,
413418
sinks,
419+
skipClientWorkerSetCheck: true,
414420
});
415421
await worker.runUntil(
416422
client.execute(workflows.upsertAndReadSearchAttributes, {

0 commit comments

Comments
 (0)