Browse Source

celerymon displays tasks filtered by name incorrectly - fixed.

Alexander A. Sosnovskiy 12 năm trước cách đây
mục cha
commit
8093ab7701
1 tập tin đã thay đổi với 8 bổ sung3 xóa
  1. 8 3
      celery/events/state.py

+ 8 - 3
celery/events/state.py

@@ -329,9 +329,14 @@ class State(object):
         Returns a list of `(uuid, task)` tuples.
 
         """
-        return self._sort_tasks_by_time([(uuid, task)
-                for uuid, task in self.itertasks(limit)
-                    if task.name == name])
+        sorted_tasks = self._sort_tasks_by_time([(uuid, task)
+                                                 for uuid, task in self.tasks.iteritems()
+                                                 if task.name == name])
+
+        if limit:
+            return sorted_tasks[0:limit]
+        else:
+            return sorted_tasks
 
     def tasks_by_worker(self, hostname, limit=None):
         """Get all tasks by worker.