log.info added when cleaning registries

main
glaslos 9 years ago
parent bd7b642251
commit a424d320a8

@ -663,6 +663,7 @@ class Worker(object):
def clean_registries(self): def clean_registries(self):
"""Runs maintenance jobs on each Queue's registries.""" """Runs maintenance jobs on each Queue's registries."""
for queue in self.queues: for queue in self.queues:
self.log.info('Cleaning registries for queue: {0}'.format(queue.name))
clean_registries(queue) clean_registries(queue)
self.last_cleaned_at = utcnow() self.last_cleaned_at = utcnow()

Loading…
Cancel
Save