Merge pull request #601 from glaslos/registry_cleanup_log_msg

log.info added when cleaning registries
main
Selwin Ong 9 years ago
commit 91177b7317

@ -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