third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'pr-gitee-worker-cluster-bugfix' into 4.3.5

Browse Source
This commit is contained in:
tjq 2023-08-14 23:21:28 +08:00
commit 74a92622a3
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/worker/WorkerClusterQueryService.java
View File

@ -75,6 +75,7 @@ public class WorkerClusterQueryService {
* @param appId appId * @param appId appId
* @return alive workers * @return alive workers
*/ */
@DesignateServer
public List<WorkerInfo> getAllAliveWorkers(Long appId) { public List<WorkerInfo> getAllAliveWorkers(Long appId) {
List<WorkerInfo> workers = Lists.newLinkedList(getWorkerInfosByAppId(appId).values()); List<WorkerInfo> workers = Lists.newLinkedList(getWorkerInfosByAppId(appId).values());
workers.removeIf(WorkerInfo::timeout); workers.removeIf(WorkerInfo::timeout);