From 9d3fc2d71b253e26fa83530a6a215e3a4881fce0 Mon Sep 17 00:00:00 2001 From: Simon Date: Thu, 21 Jun 2018 21:26:44 -0400 Subject: [PATCH] typo (again) --- task.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/task.py b/task.py index b13134c..d459644 100644 --- a/task.py +++ b/task.py @@ -204,7 +204,7 @@ class TaskDispatcher: queued_tasks = dict() pool = ThreadPoolExecutor(max_workers=10) 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() for i, server in enumerate(crawl_servers):