diff --git a/backend/src/main/java/com/bakdata/conquery/models/worker/ClusterHealthCheck.java b/backend/src/main/java/com/bakdata/conquery/models/worker/ClusterHealthCheck.java
index 1211f76a14..41c6f8d6c7 100644
--- a/backend/src/main/java/com/bakdata/conquery/models/worker/ClusterHealthCheck.java
+++ b/backend/src/main/java/com/bakdata/conquery/models/worker/ClusterHealthCheck.java
@@ -12,9 +12,9 @@
 import com.bakdata.conquery.io.mina.NetworkSession;
 import com.bakdata.conquery.mode.cluster.ClusterState;
 import com.codahale.metrics.health.HealthCheck;
-import lombok.Data;
+import lombok.RequiredArgsConstructor;
 
-@Data
+@RequiredArgsConstructor
 public class ClusterHealthCheck extends HealthCheck {
 
 	public static final String HEALTHY_MESSAGE_FMT = "All %d known shards are connected.";
@@ -38,7 +38,7 @@ protected Result check() throws Exception {
 
 		LocalDateTime now = LocalDateTime.now();
 		List<ShardNodeInformation> timeoutShards = nodeProvider.get().stream()
-															   .filter((status) -> heartbeatTimeout.minus(Duration.between(now, status.getLastStatusTime()))
+															   .filter((status) -> heartbeatTimeout.minus(Duration.between(status.getLastStatusTime(), now).abs())
 																								   .isNegative()).toList();
 
 		if (!timeoutShards.isEmpty()) {