Heartbeat should now work also on distributed systems

InWork · Apr 17, 2015 · e878263 · e878263
1 parent 3c67abc
commit e878263
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/lib/queue_dispatcher/acts_as_task_queue.rb b/lib/queue_dispatcher/acts_as_task_queue.rb
@@ -66,9 +66,8 @@ def pid_running?(pid)
 
       # Check if QueueDispatcher is running.
       def qd_running?
-        hb_tqs = TaskQueue.where(state: 'heartbeat')
         running = false
-        hb_tqs.each { |tq| running = true if pid_running?(tq.pid) && tq.updated_at > 1.minute.ago }
+        TaskQueue.where(state: 'heartbeat').each { |tq| running = true if tq.updated_at > 1.minute.ago }
         running
       end
 

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