diff --git a/master/internal/core.go b/master/internal/core.go index 3ae3787a2a11..a14e20e522f0 100644 --- a/master/internal/core.go +++ b/master/internal/core.go @@ -616,6 +616,7 @@ func (m *Master) rwCoordinatorWebSocket(socket *websocket.Conn, c echo.Context) func updateClusterHeartbeat(ctx context.Context, db *db.PgDB) { t := time.NewTicker(10 * time.Minute) defer t.Stop() + for { currentTime := time.Now().UTC().Truncate(time.Millisecond) err := db.UpdateClusterHeartBeat(currentTime)