Skip to content

Commit

Permalink
Merge branch 'staging'
Browse files Browse the repository at this point in the history
  • Loading branch information
eugenk committed Nov 2, 2015
2 parents c29a180 + 6f2fa4d commit c1d0ca2
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
5 changes: 4 additions & 1 deletion config/god/app.rb
Expand Up @@ -16,6 +16,9 @@
watch 'hets', 1
end

# one worker for hets load balancing
watch 'hets_load_balancing', 1

# one worker for the default queue
watch 'default', 5

Expand All @@ -25,7 +28,7 @@
watch 'priority_push', 1
else
# one worker for all queues
watch %w(hets default sequential priority_push), 1
watch %w(hets hets_load_balancing default sequential priority_push), 1
end
end

Expand Down
2 changes: 1 addition & 1 deletion lib/hets_instance_force_free_worker.rb
@@ -1,5 +1,5 @@
class HetsInstanceForceFreeWorker < BaseWorker
sidekiq_options queue: 'default'
sidekiq_options queue: 'hets_load_balancing'

def perform(hets_instance_id)
Semaphore.exclusively(HetsInstance::MUTEX_KEY) do
Expand Down

0 comments on commit c1d0ca2

Please sign in to comment.