pkg/jobqueue: fix worker status update query

The workers table should be updated, not the heartbeats. Currently every
worker is reregisterig every minute.
This commit is contained in:
Sanne Raymaekers 2024-01-31 12:25:01 +01:00 committed by Tomáš Hozza
parent 3e31ebfbb1
commit de548c36f3

View file

@ -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 {