make sure to remove the stopped dispatcher threads from ASYNC_THREADS

This commit is contained in:
Noam Meltzer 2016-06-17 23:58:22 +03:00
parent 881d1d0e25
commit a30411c9fa

View file

@ -382,6 +382,7 @@ class Updater(object):
for i, thr in enumerate(threads):
self.logger.debug('Waiting for async thread {0}/{1} to end'.format(i + 1, total))
thr.join()
dispatcher.ASYNC_THREADS.remove(thr)
self.logger.debug('async thread {0}/{1} has ended'.format(i + 1, total))
def _join_threads(self):