Bugfix: reset_immediately! does not kill the heartbeat task_queue

InWork · Sep 25, 2015 · 736161a · 736161a
1 parent f869af6
commit 736161a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/README.rdoc b/README.rdoc
@@ -1,4 +1,4 @@
-= QueueDispatcher for Rails3
+= QueueDispatcher for Rails3 / Rails4
 
 {<img src="https://codeclimate.com/github/InWork/queue_dispatcher.png" />}[https://codeclimate.com/github/InWork/queue_dispatcher]
 

diff --git a/lib/queue_dispatcher/acts_as_task_queue.rb b/lib/queue_dispatcher/acts_as_task_queue.rb
@@ -106,7 +106,7 @@ def find_or_create_by_name(name, options = {})
 
       # Kill all running TaskQueues immediately and destroy them.
       def reset_immediately!
-        all.each do |tq|
+        self.where('state != ?', 'heartbeat').each do |tq|
           tq.update_attributes state: 'aborted'
 
           # Kill the TaskQueue with SIGKILL

diff --git a/lib/queue_dispatcher/version.rb b/lib/queue_dispatcher/version.rb
@@ -1,3 +1,3 @@
 module QueueDispatcher
-  VERSION = "2.5.3"
+  VERSION = "2.5.4"
 end