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)