ソースを参照

Dump reserved now works even for eventloop and when rate limits disabled

Ask Solem 12 年 前
コミット
c35c77d250
1 ファイル変更1 行追加2 行削除
  1. 1 2
      celery/worker/control.py

+ 1 - 2
celery/worker/control.py

@@ -166,8 +166,7 @@ def dump_schedule(panel, safe=False, **kwargs):
 
 
 @Panel.register
 @Panel.register
 def dump_reserved(panel, safe=False, **kwargs):
 def dump_reserved(panel, safe=False, **kwargs):
-    ready_queue = panel.consumer.ready_queue
-    reserved = ready_queue.items
+    reserved = state.reserved_requests
     if not reserved:
     if not reserved:
         logger.debug('--Empty queue--')
         logger.debug('--Empty queue--')
         return []
         return []