Correctly ending loggers

This commit is contained in:
Andrew Melton 2013-11-06 14:22:41 -05:00
parent 6680996675
commit eaf7f9a290
3 changed files with 6 additions and 3 deletions

View File

@ -180,7 +180,8 @@ class LogListener:
def end(self):
self.queue.put_nowait(None)
self.thread.join()
self.logger.handler.close()
for handler in self.logger.handlers:
handler.close()
def get_queue(logger_name):

View File

@ -86,7 +86,8 @@ if __name__ == '__main__':
verifier.run()
verifier_config.load()
log_listener = stacklog.LogListener(_get_parent_logger()).start()
log_listener = stacklog.LogListener(_get_parent_logger())
log_listener.start()
for exchange in verifier_config.topics().keys():
process = Process(target=make_and_start_verifier, args=(exchange,))
process.start()

View File

@ -36,7 +36,8 @@ def kill_time(signal, frame):
if __name__ == '__main__':
log_listener = stacklog.LogListener(_get_parent_logger()).start()
log_listener = stacklog.LogListener(_get_parent_logger())
log_listener.start()
for deployment in config.deployments():
if deployment.get('enabled', True):
db_deployment, new = db.get_or_create_deployment(deployment['name'])