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 @@ -96,6 +96,7 @@ public void stickyQueueBacklogResetTest() {
9696 .setKind (TaskQueueKind .TASK_QUEUE_KIND_STICKY )
9797 .build ())
9898 .setNamespace ("default" )
99+ .setWorkerInstanceKey ("test-instance-key" )
99100 .build ())))
100101 .thenReturn (pollResponse );
101102 if (throwOnPoll ) {
Original file line number Diff line number Diff line change @@ -73,6 +73,7 @@ public void concurrentPollRequestLockTest() throws Exception {
7373 SingleWorkerOptions .newBuilder ()
7474 .setIdentity ("test_identity" )
7575 .setBuildId (UUID .randomUUID ().toString ())
76+ .setWorkerInstanceKey (UUID .randomUUID ().toString ())
7677 .setPollerOptions (
7778 PollerOptions .newBuilder ()
7879 .setPollerBehavior (new PollerBehaviorSimpleMaximum (3 ))
@@ -243,6 +244,7 @@ public void respondWorkflowTaskFailureMetricTest() throws Exception {
243244 SingleWorkerOptions .newBuilder ()
244245 .setIdentity ("test_identity" )
245246 .setBuildId (UUID .randomUUID ().toString ())
247+ .setWorkerInstanceKey (UUID .randomUUID ().toString ())
246248 .setPollerOptions (
247249 PollerOptions .newBuilder ()
248250 .setPollerBehavior (new PollerBehaviorSimpleMaximum (1 ))
@@ -386,6 +388,7 @@ public boolean isAnyTypeSupported() {
386388 SingleWorkerOptions .newBuilder ()
387389 .setIdentity ("test_identity" )
388390 .setBuildId (UUID .randomUUID ().toString ())
391+ .setWorkerInstanceKey (UUID .randomUUID ().toString ())
389392 .setPollerOptions (
390393 PollerOptions .newBuilder ()
391394 .setPollerBehavior (new PollerBehaviorSimpleMaximum (1 ))
You can’t perform that action at this time.
0 commit comments