diff --git a/cmd/apollo-worker/main.go b/cmd/apollo-worker/main.go index 9908ffe..09e3c6d 100644 --- a/cmd/apollo-worker/main.go +++ b/cmd/apollo-worker/main.go @@ -103,7 +103,7 @@ func accountWorker(id int, rc *reddit.Client, db *sql.DB, logger *log.Logger, st // Set latest message we alerted on latestMsg := msgs.MessageListing.Messages[0] - latency := latestMsg.CreatedAt - float64(now) + latency := float64(now) - latestMsg.CreatedAt statsd.Histogram("apollo.notification.latency", latency, []string{}, rate) _, err = tx.Exec(`UPDATE accounts SET last_message_id = $1 WHERE id = $2`, latestMsg.FullName(), account.ID)