typo (again)

This commit is contained in:
Simon 2018-06-21 21:26:44 -04:00
parent efd1981e6f
commit 9d3fc2d71b

View File

@ -204,7 +204,7 @@ class TaskDispatcher:
queued_tasks = dict() queued_tasks = dict()
pool = ThreadPoolExecutor(max_workers=10) pool = ThreadPoolExecutor(max_workers=10)
crawl_servers = self.db.get_crawl_servers() crawl_servers = self.db.get_crawl_servers()
responses = list(pool.map(lambda server: server.fetch_queued_tasks())) responses = list(pool.map(lambda s: s.fetch_queued_tasks(), crawl_servers))
pool.shutdown() pool.shutdown()
for i, server in enumerate(crawl_servers): for i, server in enumerate(crawl_servers):