From 809b0758045f4a19c52211ab3b46f69a10dcf25d Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Wed, 7 Jul 2021 18:44:14 -0400 Subject: [PATCH] fix float issue --- cmd/apollo-worker/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/apollo-worker/main.go b/cmd/apollo-worker/main.go index 13cbe02..992215c 100644 --- a/cmd/apollo-worker/main.go +++ b/cmd/apollo-worker/main.go @@ -64,7 +64,7 @@ func accountWorker(id int, rc *reddit.Client, db *sql.DB, logger *log.Logger, st query := ` SELECT id, username, access_token, refresh_token, expires_at, last_message_id, last_checked_at FROM accounts - WHERE last_checked_at <= $1 - 5 + WHERE last_checked_at <= $1::float - 5 ORDER BY last_checked_at LIMIT 1 FOR UPDATE SKIP LOCKED` @@ -81,7 +81,7 @@ func accountWorker(id int, rc *reddit.Client, db *sql.DB, logger *log.Logger, st if account.LastCheckedAt > 0 { latency := now - account.LastCheckedAt - float64(backoff) - statsd.Histogram("apollo.queue.delay", float64(latency), []string{}, rate) + statsd.Histogram("apollo.queue.delay", latency, []string{}, rate) } _, err = tx.Exec(`UPDATE accounts SET last_checked_at = $1 WHERE id = $2`, now, account.ID)