diff --git a/internal/cmd/scheduler.go b/internal/cmd/scheduler.go index 5e202e9..7860d29 100644 --- a/internal/cmd/scheduler.go +++ b/internal/cmd/scheduler.go @@ -416,7 +416,7 @@ func enqueueAccounts(ctx context.Context, logger *zap.Logger, statsd *statsd.Cli FOR UPDATE SKIP LOCKED LIMIT %d ) - RETURNING accounts.account_id`, maxNotificationChecks) + RETURNING accounts.reddit_account_id`, maxNotificationChecks) rows, err := tx.Query(ctx, stmt, now, next) if err != nil { return err