Skip to content

Commit 51563a3

Browse files
committed
try without filtering to 100, match Core's filtering with task queue
1 parent 1dc3b70 commit 51563a3

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

temporal-sdk/src/test/java/io/temporal/worker/WorkerHeartbeatIntegrationTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -747,11 +747,11 @@ private List<WorkerHeartbeat> listWorkersForQueue(String taskQueue) {
747747
ListWorkersRequest.newBuilder()
748748
.setNamespace(
749749
testWorkflowRule.getWorkflowClient().getOptions().getNamespace())
750-
.setPageSize(100)
750+
.setQuery("TaskQueue = \"" + taskQueue + "\"")
751+
.setPageSize(200)
751752
.build());
752753
return resp.getWorkersInfoList().stream()
753754
.map(info -> info.getWorkerHeartbeat())
754-
.filter(hb -> hb.getTaskQueue().equals(taskQueue))
755755
.collect(Collectors.toList());
756756
} catch (io.grpc.StatusRuntimeException e) {
757757
if (e.getStatus().getCode() == io.grpc.Status.Code.RESOURCE_EXHAUSTED) {

0 commit comments

Comments
 (0)