From 5e52c711bc9029c0ad7286ebd4722b1385d45ce7 Mon Sep 17 00:00:00 2001 From: shizhendong Date: Fri, 19 Jul 2024 17:52:42 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=A1=A5=E5=85=85=20heartbeat=20?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E6=9B=B4=E6=96=B0=20runer.last=5Fheartbeat?= =?UTF-8?q?=5Ftimestamp=20value?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../asw/module/runner/controller/RunnerController.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java b/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java index d9d119f..e7499c8 100644 --- a/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java +++ b/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java @@ -97,6 +97,11 @@ public class RunnerController { return; } + // update last_heartbeat_timestamp + runnerService.update(new LambdaUpdateWrapper() + .set(RunnerEntity::getLastHeartbeatTimestamp, System.currentTimeMillis()) + .eq(RunnerEntity::getId, runner.getId())); + // findjob by platform String platform = platformMap.entrySet().stream().filter(entry -> entry.getValue() > 0).findFirst().map(entry -> entry.getKey()).orElseGet(null); JobEntity job = jobService.assignPendingJob(runner.getId(), platform);