File tree Expand file tree Collapse file tree
temporal-sdk/src/test/java/io/temporal/internal/worker Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -98,6 +98,7 @@ public void stickyQueueBacklogResetTest() {
9898 .setKind (TaskQueueKind .TASK_QUEUE_KIND_STICKY )
9999 .build ())
100100 .setNamespace ("default" )
101+ .setWorkerInstanceKey ("test-instance-key" )
101102 .build ())))
102103 .thenReturn (pollResponse );
103104 if (throwOnPoll ) {
Original file line number Diff line number Diff line change @@ -80,6 +80,7 @@ public void concurrentPollRequestLockTest() throws Exception {
8080 SingleWorkerOptions .newBuilder ()
8181 .setIdentity ("test_identity" )
8282 .setBuildId (UUID .randomUUID ().toString ())
83+ .setWorkerInstanceKey (UUID .randomUUID ().toString ())
8384 .setPollerOptions (
8485 PollerOptions .newBuilder ()
8586 .setPollerBehavior (new PollerBehaviorSimpleMaximum (3 ))
@@ -252,6 +253,7 @@ public void respondWorkflowTaskFailureMetricTest() throws Exception {
252253 SingleWorkerOptions .newBuilder ()
253254 .setIdentity ("test_identity" )
254255 .setBuildId (UUID .randomUUID ().toString ())
256+ .setWorkerInstanceKey (UUID .randomUUID ().toString ())
255257 .setPollerOptions (
256258 PollerOptions .newBuilder ()
257259 .setPollerBehavior (new PollerBehaviorSimpleMaximum (1 ))
@@ -397,6 +399,7 @@ public boolean isAnyTypeSupported() {
397399 SingleWorkerOptions .newBuilder ()
398400 .setIdentity ("test_identity" )
399401 .setBuildId (UUID .randomUUID ().toString ())
402+ .setWorkerInstanceKey (UUID .randomUUID ().toString ())
400403 .setPollerOptions (
401404 PollerOptions .newBuilder ()
402405 .setPollerBehavior (new PollerBehaviorSimpleMaximum (1 ))
You can’t perform that action at this time.
0 commit comments