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);