Set new queues for jobs

2026-05-01 10:45:21 +00:00 · 2025-05-05 10:09:55 -04:00
parent 6a89a777e8
commit e433667c03
21 changed files with 29 additions and 14 deletions
--- a/app/jobs/attempt_project_repo_mapping_job.rb
+++ b/app/jobs/attempt_project_repo_mapping_job.rb
@@ -1,5 +1,5 @@
 class AttemptProjectRepoMappingJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  include GoodJob::ActiveJobExtensions::Concurrency

--- a/app/jobs/cache/active_projects_job.rb
+++ b/app/jobs/cache/active_projects_job.rb
@@ -1,4 +1,6 @@
 class Cache::ActiveProjectsJob < Cache::ActivityJob
+  queue_as :latency_10s
+
  private

  def cache_expiration
--- a/app/jobs/cache/active_users_graph_data_job.rb
+++ b/app/jobs/cache/active_users_graph_data_job.rb
@@ -1,4 +1,6 @@
 class Cache::ActiveUsersGraphDataJob < Cache::ActivityJob
+  queue_as :latency_10s
+
  private

  def calculate
--- a/app/jobs/cache/currently_hacking_job.rb
+++ b/app/jobs/cache/currently_hacking_job.rb
@@ -1,4 +1,6 @@
 class Cache::CurrentlyHackingJob < Cache::ActivityJob
+  queue_as :latency_10s
+
  private

  def cache_expiration
--- a/app/jobs/cache/home_stats_job.rb
+++ b/app/jobs/cache/home_stats_job.rb
@@ -1,4 +1,6 @@
 class Cache::HomeStatsJob < Cache::ActivityJob
+  queue_as :latency_1m
+
  private

  def calculate
--- a/app/jobs/cache/minutes_logged_job.rb
+++ b/app/jobs/cache/minutes_logged_job.rb
@@ -1,4 +1,6 @@
 class Cache::MinutesLoggedJob < Cache::ActivityJob
+  queue_as :latency_10s
+
  private

  def calculate
--- a/app/jobs/cache/social_proof_job.rb
+++ b/app/jobs/cache/social_proof_job.rb
@@ -1,4 +1,6 @@
 class Cache::SocialProofJob < Cache::ActivityJob
+  queue_as :latency_10s
+
  private

  def calculate
--- a/app/jobs/handle_email_signin_job.rb
+++ b/app/jobs/handle_email_signin_job.rb
@@ -1,5 +1,5 @@
 class HandleEmailSigninJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  def perform(email)
    email_address = ActiveRecord::Base.transaction do
--- a/app/jobs/leaderboard_update_job.rb
+++ b/app/jobs/leaderboard_update_job.rb
@@ -1,5 +1,6 @@
 class LeaderboardUpdateJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s
+
  BATCH_SIZE = 1000

  include GoodJob::ActiveJobExtensions::Concurrency
--- a/app/jobs/one_time/migrate_user_from_hackatime_job.rb
+++ b/app/jobs/one_time/migrate_user_from_hackatime_job.rb
@@ -1,5 +1,5 @@
 class OneTime::MigrateUserFromHackatimeJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_1m

  include GoodJob::ActiveJobExtensions::Concurrency

--- a/app/jobs/sailors_log_notify_job.rb
+++ b/app/jobs/sailors_log_notify_job.rb
@@ -1,5 +1,5 @@
 class SailorsLogNotifyJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  include GoodJob::ActiveJobExtensions::Concurrency

--- a/app/jobs/sailors_log_poll_for_changes_job.rb
+++ b/app/jobs/sailors_log_poll_for_changes_job.rb
@@ -1,5 +1,5 @@
 class SailorsLogPollForChangesJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  include GoodJob::ActiveJobExtensions::Concurrency

--- a/app/jobs/sailors_log_teletype_job.rb
+++ b/app/jobs/sailors_log_teletype_job.rb
@@ -1,5 +1,5 @@
 class SailorsLogTeletypeJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  def perform(message)
    HTTP.auth("Bearer #{ENV['TELETYPE_API_KEY']}")
--- a/app/jobs/scan_github_repos_job.rb
+++ b/app/jobs/scan_github_repos_job.rb
@@ -1,5 +1,5 @@
 class ScanGithubReposJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_1m

  include GoodJob::ActiveJobExtensions::Concurrency

--- a/app/jobs/slack_command/sailors_log_help_job.rb
+++ b/app/jobs/slack_command/sailors_log_help_job.rb
@@ -1,5 +1,5 @@
 class SlackCommand::SailorsLogHelpJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  def perform(response_url)
    HTTP.post(response_url, json: {
--- a/app/jobs/slack_command/sailors_log_job.rb
+++ b/app/jobs/slack_command/sailors_log_job.rb
@@ -1,4 +1,6 @@
 class SlackCommand::SailorsLogJob < ApplicationJob
+  queue_as :latency_10s
+
  def perform(params)
    case params[:text].downcase.strip
    when "on", "off"
--- a/app/jobs/slack_command/sailors_log_leaderboard_job.rb
+++ b/app/jobs/slack_command/sailors_log_leaderboard_job.rb
@@ -1,5 +1,5 @@
 class SlackCommand::SailorsLogLeaderboardJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s
  include ApplicationHelper

  def perform(slack_uid, channel_id, response_url)
--- a/app/jobs/slack_command/sailors_log_on_off_job.rb
+++ b/app/jobs/slack_command/sailors_log_on_off_job.rb
@@ -1,5 +1,5 @@
 class SlackCommand::SailorsLogOnOffJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  def perform(slack_uid, slack_channel_id, user_name, response_url, enabled)
    # set preference for the user
--- a/app/jobs/slack_command/update_slack_channel_cache_job.rb
+++ b/app/jobs/slack_command/update_slack_channel_cache_job.rb
@@ -1,5 +1,5 @@
 class SlackCommand::UpdateSlackChannelCacheJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_10s

  def perform
    channels = SailorsLogNotificationPreference.where(enabled: true).distinct.pluck(:slack_channel_id)
--- a/app/jobs/slack_username_update_job.rb
+++ b/app/jobs/slack_username_update_job.rb
@@ -1,5 +1,5 @@
 class SlackUsernameUpdateJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_1m

  include GoodJob::ActiveJobExtensions::Concurrency

--- a/app/jobs/user_slack_status_update_job.rb
+++ b/app/jobs/user_slack_status_update_job.rb
@@ -1,5 +1,5 @@
 class UserSlackStatusUpdateJob < ApplicationJob
-  queue_as :default
+  queue_as :latency_1m
  BATCH_SIZE = 25

  def perform