Update delayed_job_sequel to process jobs from killed workers

Update index on delayed_jobs to include locked_by [#84346198]
cloudfoundry · Dec 15, 2014 · 9cf9bf9 · 9cf9bf9
1 parent 32c7866
commit 9cf9bf9
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/Gemfile.lock b/Gemfile.lock
@@ -28,7 +28,7 @@ GIT
 
 GIT
   remote: https://github.com/cloudfoundry/delayed_job_sequel.git
-  revision: c9cfd1d094434bb0300d6175909d03a3672f5fc7
+  revision: d018c527b6638c2787688135ce0d6298d096490c
   specs:
     delayed_job_sequel (4.0.1)
       delayed_job (~> 4.0.0)

diff --git a/db/migrations/20141215184824_add_locked_by_to_delayed_jobs_index.rb b/db/migrations/20141215184824_add_locked_by_to_delayed_jobs_index.rb
@@ -0,0 +1,11 @@
+Sequel.migration do
+  up do
+    drop_index :delayed_jobs, [:queue, :locked_at, :failed_at, :run_at], name: :delayed_jobs_reserve
+    add_index :delayed_jobs, [:queue, :locked_at, :locked_by, :failed_at, :run_at], name: :delayed_jobs_reserve
+  end
+
+  down do
+    drop_index :delayed_jobs, [:queue, :locked_at, :locked_by, :failed_at, :run_at], name: :delayed_jobs_reserve
+    add_index :delayed_jobs, [:queue, :locked_at, :failed_at, :run_at], name: :delayed_jobs_reserve
+  end
+end