From 011cd6686070c0fd4ff975737b833726534dd0dd Mon Sep 17 00:00:00 2001 From: Cody Cutrer Date: Wed, 26 Jun 2013 13:57:56 -0600 Subject: [PATCH] strand per shard for due date cacher Change-Id: I6e4ba16a3108af9ea462ebfc3ee30e4d65ac54d6 Reviewed-on: https://gerrit.instructure.com/21763 Tested-by: Jenkins Reviewed-by: Cody Cutrer Product-Review: Cody Cutrer QA-Review: Cody Cutrer --- lib/due_date_cacher.rb | 3 ++- spec/lib/due_date_cacher_spec.rb | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/lib/due_date_cacher.rb b/lib/due_date_cacher.rb index 5c590adb258..879f657ebb3 100644 --- a/lib/due_date_cacher.rb +++ b/lib/due_date_cacher.rb @@ -6,7 +6,8 @@ class DueDateCacher def self.recompute_batch(assignments) new(assignments).send_later_if_production_enqueue_args(:recompute, - :strand => "cached_due_date:calculator:batch") + :strand => "cached_due_date:calculator:batch:#{Shard.current.id}", + :priority => Delayed::LOWER_PRIORITY) end # expects all assignments to be on the same shard diff --git a/spec/lib/due_date_cacher_spec.rb b/spec/lib/due_date_cacher_spec.rb index da3dd03e18d..db1714f0820 100644 --- a/spec/lib/due_date_cacher_spec.rb +++ b/spec/lib/due_date_cacher_spec.rb @@ -67,7 +67,8 @@ describe DueDateCacher do it "should queue a delayed job on a batch-specific singleton strand in production" do @instance.expects(:send_later_if_production_enqueue_args). - with(:recompute, :strand => "cached_due_date:calculator:batch") + with(:recompute, :strand => "cached_due_date:calculator:batch:#{Shard.current.id}", + :priority => Delayed::LOWER_PRIORITY) DueDateCacher.recompute_batch(@assignments) end end