Skip to content

Commit d057062

Browse files
codebendercodebender
committed
organize sidekiq jobs into logical queue names
https://assembly.com/coderwall/bounties/422 SearchSyncJob must use search_sync queue for uniqueness SearchSyncJob depends on its queue being its own queue, because that is how it enforces uniqueness
1 parent 73fe695 commit d057062

File tree

86 files changed

+467
-66
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

86 files changed

+467
-66
lines changed

‎app/jobs/analyze_spam_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class AnalyzeSpamJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :medium
4+
sidekiq_options queue: :data_cleanup
55

66
def perform(spammable)
77
return if Rails.env.test? || Rails.env.development?

‎app/jobs/assign_networks_job.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class AssignNetworksJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :low
4+
sidekiq_options queue: :network
55

66
def perform(username)
77
user = User.find_by_username(username)
@@ -11,4 +11,4 @@ def perform(username)
1111
end
1212
end
1313
end
14-
end
14+
end

‎app/jobs/award_job.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,9 @@ class AwardJob
22
include Sidekiq::Worker
33
include Awards
44

5-
sidekiq_options queue: :high
5+
sidekiq_options queue: :user
66

77
def perform(badge, date, provider, candidate)
88
award(badge.constantize, date, provider, candidate)
99
end
10-
end
10+
end

‎app/jobs/award_user_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class AwardUserJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :low
4+
sidekiq_options queue: :user
55

66
def perform(username, badges)
77
user = User.with_username(username)

‎app/jobs/build_activity_stream_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class BuildActivityStreamJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :medium
4+
sidekiq_options queue: :timeline
55

66
def perform(username)
77
user = User.with_username(username)

‎app/jobs/cleanup_protips_associate_zombie_upvotes_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class CleanupProtipsAssociateZombieUpvotesJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :low
4+
sidekiq_options queue: :data_cleanup
55

66
def perform
77
Like.joins('inner join users on users.tracking_code = likes.tracking_code').

‎app/jobs/clear_expired_sessions_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class ClearExpiredSessionsJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :low
4+
sidekiq_options queue: :data_cleanup
55

66
def perform
77
ActiveRecord::SessionStore::Session.delete_all(["updated_at < ?", 7.days.ago])

‎app/jobs/create_github_profile_job.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,11 @@
22

33
class CreateGithubProfileJob
44
include Sidekiq::Worker
5-
sidekiq_options queue: :low
5+
sidekiq_options queue: :github
66

77
def perform
88
User.where('github is not null').find_each do |user|
99
user.create_github_profile if user.github_profile.blank?
1010
end
1111
end
12-
end
12+
end

‎app/jobs/create_network_job.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class CreateNetworkJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :low
4+
sidekiq_options queue: :network
55

66
def perform(tag)
77
top_tags = Protip.trending_topics
@@ -13,4 +13,4 @@ def perform(tag)
1313
Network.create(name: tag, tags: sub_tags)
1414
end
1515
end
16-
end
16+
end

‎app/jobs/deactivate_team_jobs_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
class DeactivateTeamJobsJob
22
include Sidekiq::Worker
33

4-
sidekiq_options queue: :low
4+
sidekiq_options queue: :team
55

66
def perform(id)
77
team = Team.find(id)

0 commit comments

Comments
 (0)