feat(server) use about_time to show timing and throughput stats

clearly/server.py

@@ -5,6 +5,7 @@
 import operator
 import re
 
+from about_time import about_time
 from celery.events.state import Task, Worker
 
 from .event_core.event_listener import EventListener
@@ -117,7 +118,12 @@ def scondition(task):
                        self.listener.memory.tasks_by_time(limit=limit or None,
                                                           reverse=reverse)
                        if pcondition(task) and scondition(task))
-        for task in found_tasks:
+
+        def callback(t):
+            logger.debug('%s iterated %d tasks in %s (%s)', self.filter_tasks.__name__,
+                         t.count, t.duration_human, t.throughput_human)
+
+        for task in about_time(callback, found_tasks):
             yield ClearlyServer._event_to_pb(task)[1]
 
     def filter_workers(self, request, context):
@@ -134,7 +140,12 @@ def hcondition(worker):
                          sorted(self.listener.memory.workers.values(),
                                 key=WORKER_HOSTNAME_OP)
                          if hcondition(worker))
-        for worker in found_workers:
+
+        def callback(t):
+            logger.debug('%s iterated %d workers in %s (%s)', self.filter_workers.__name__,
+                         t.count, t.duration_human, t.throughput_human)
+
+        for worker in about_time(callback, found_workers):
             yield ClearlyServer._event_to_pb(worker)[1]
 
     def find_task(self, request, context):

setup.py

@@ -15,6 +15,7 @@
     'grpcio',
     'protobuf',
     'click',
+    'about-time',
 ]
 if sys.version_info[0] == 2:
     install_requires.append('futures')