fix manager stats in worker

cenkalti · Jul 23, 2013 · 4dbfd51 · 4dbfd51
1 parent d7ee09c
commit 4dbfd51
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kuyruk/worker.py b/kuyruk/worker.py
@@ -325,7 +325,7 @@ def warm_shutdown(self, sigint=False):
 
     def get_stats(self):
         """Generate stats to be sent to manager."""
-        method = self.queue.declare().method
+        method = self.queue.declare(force=True).method
         try:
             current_task = self.current_task.name
         except AttributeError: