fix(continuous): keep meta_id unchanged between continuous jobs

abak-press · Jun 19, 2013 · 9561852 · 9561852
1 parent 9ef9554
commit 9561852
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/lib/resque/integration/continuous.rb b/lib/resque/integration/continuous.rb
@@ -50,7 +50,8 @@ def after_perform_continue(*args)
         if continued?
           args = if @continued.any?
             if unique?
-              [meta_id(*args)] + @continued
+              meta_id = args.first # we should keep meta_id as first argument
+              [meta_id] + @continued
             else
               @continued
             end

diff --git a/spec/resque/integration/continuous_spec.rb b/spec/resque/integration/continuous_spec.rb
@@ -80,6 +80,20 @@ def self.execute(x, y)
       # clean the queue
       Resque.dequeue(ContinuousUniqueJobTest)
     end
+
+    it 'should enqueue job with the same meta_id' do
+      ContinuousUniqueJobTest.enqueue(3, 1)
+
+      job1 = Resque.reserve(ContinuousUniqueJobTest.queue)
+      meta1 = job1.payload['args'].first
+
+      job1.perform
+
+      job2 = Resque.reserve(ContinuousUniqueJobTest.queue)
+      meta2 = job2.payload['args'].first
+
+      meta1.should eq meta2
+    end
   end
 
   context 'when called without arguments' do