From f62d57fbf058577adf4b7dcb70d697f9b22b0c2a Mon Sep 17 00:00:00 2001 From: Max Wofford Date: Mon, 26 May 2025 18:37:37 -0400 Subject: [PATCH] Fix queueing on jobs still in default queue --- app/jobs/sync_all_user_repo_events_job.rb | 5 ++++- app/jobs/update_slack_neighborhood_channels_job.rb | 7 +++++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/app/jobs/sync_all_user_repo_events_job.rb b/app/jobs/sync_all_user_repo_events_job.rb index a31f1cf..252611a 100644 --- a/app/jobs/sync_all_user_repo_events_job.rb +++ b/app/jobs/sync_all_user_repo_events_job.rb @@ -1,5 +1,8 @@ class SyncAllUserRepoEventsJob < ApplicationJob - queue_as :default # Or a more specific queue like :batch_enqueueing + queue_as :literally_whenever + + include HasEnqueueControl + enqueue_limit def perform Rails.logger.info "Kicking off SyncAllUserRepoEventsJob" diff --git a/app/jobs/update_slack_neighborhood_channels_job.rb b/app/jobs/update_slack_neighborhood_channels_job.rb index 14c1e25..29c3b3b 100644 --- a/app/jobs/update_slack_neighborhood_channels_job.rb +++ b/app/jobs/update_slack_neighborhood_channels_job.rb @@ -1,8 +1,11 @@ class UpdateSlackNeighborhoodChannelsJob < ApplicationJob - queue_as :default + queue_as :literally_whenever + + include HasEnqueueControl + enqueue_limit def perform - User.where.not(slack_uid: nil).find_each(batch_size: 100) do |user| + User.where.not(slack_uid: nil).find_each(batch_size: 1000) do |user| user.set_neighborhood_channel user.save! if user.changed? end