From d27f4604b92becd05e13f896bb840e0e6822910b Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Wed, 2 Nov 2022 01:11:49 -0400 Subject: [PATCH] fix casting --- internal/worker/stuck_notifications.go | 2 +- internal/worker/subreddits.go | 2 +- internal/worker/trending.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/worker/stuck_notifications.go b/internal/worker/stuck_notifications.go index d707f5e..8ad1923 100644 --- a/internal/worker/stuck_notifications.go +++ b/internal/worker/stuck_notifications.go @@ -50,7 +50,7 @@ func (snw *stuckNotificationsWorker) Process(ctx context.Context, args ...interf _ = snw.statsd.Histogram("apollo.consumer.runtime", float64(elapsed), []string{"queue:stuck-notifications"}, 0.1) }() - id := args[0].(int64) + id := int64(args[0].(float64)) snw.logger.Debug("starting job", zap.Int64("account#id", id)) account, err := snw.accountRepo.GetByID(ctx, id) diff --git a/internal/worker/subreddits.go b/internal/worker/subreddits.go index e1903ba..c950977 100644 --- a/internal/worker/subreddits.go +++ b/internal/worker/subreddits.go @@ -79,7 +79,7 @@ func NewSubredditsWorker(ctx context.Context, logger *zap.Logger, statsd *statsd } func (sw *subredditsWorker) Process(ctx context.Context, args ...interface{}) error { - id := args[0].(int64) + id := int64(args[0].(float64)) sw.logger.Debug("starting job", zap.Int64("subreddit#id", id)) subreddit, err := sw.subredditRepo.GetByID(ctx, id) diff --git a/internal/worker/trending.go b/internal/worker/trending.go index 97b4f85..e6e20e7 100644 --- a/internal/worker/trending.go +++ b/internal/worker/trending.go @@ -75,7 +75,7 @@ func NewTrendingWorker(ctx context.Context, logger *zap.Logger, statsd *statsd.C } func (tw *trendingWorker) Process(ctx context.Context, args ...interface{}) error { - id := args[0].(int64) + id := int64(args[0].(float64)) tw.logger.Debug("starting job", zap.Int64("subreddit#id", id)) subreddit, err := tw.subredditRepo.GetByID(ctx, id)