From de548c36f3e1a6b87a4df84c2e23ba0c839883cf Mon Sep 17 00:00:00 2001
From: Sanne Raymaekers <sanne.raymaekers@gmail.com>
Date: Wed, 31 Jan 2024 12:25:01 +0100
Subject: [PATCH] pkg/jobqueue: fix worker status update query

The workers table should be updated, not the heartbeats. Currently every
worker is reregisterig every minute.
---
 pkg/jobqueue/dbjobqueue/dbjobqueue.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pkg/jobqueue/dbjobqueue/dbjobqueue.go b/pkg/jobqueue/dbjobqueue/dbjobqueue.go
index be1bda07b..53e329eb1 100644
--- a/pkg/jobqueue/dbjobqueue/dbjobqueue.go
+++ b/pkg/jobqueue/dbjobqueue/dbjobqueue.go
@@ -120,7 +120,7 @@ const (
 		INSERT INTO workers(worker_id, arch, heartbeat)
 		VALUES($1, $2, now())`
 	sqlUpdateWorkerStatus = `
-		UPDATE heartbeats
+		UPDATE workers
 		SET heartbeat = now()
 		WHERE worker_id = $1`
 	sqlQueryWorkers = `
@@ -746,6 +746,7 @@ func (q *DBJobQueue) UpdateWorkerStatus(workerID uuid.UUID) error {
 	}
 	return nil
 }
+
 func (q *DBJobQueue) Workers(olderThan time.Duration) ([]jobqueue.Worker, error) {
 	conn, err := q.pool.Acquire(context.Background())
 	if err != nil {