fixups

Shoobx · Mar 13, 2020 · e4840ef · e4840ef
1 parent fb0a690
commit e4840ef
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/migrant/engine.py b/src/migrant/engine.py
@@ -7,8 +7,6 @@
 import multiprocessing
 
 log = logging.getLogger(__name__)
-logger = multiprocessing.log_to_stderr()
-logger.setLevel(logging.WARNING)
 
 
 from migrant import exceptions
@@ -44,7 +42,7 @@ def _update(self, db, target_id=None):
     def update(self, target_id=None):
         target_id = self.pick_rev_id(target_id)
         conns = self.backend.generate_connections()
-        with Pool() as pool:
+        with multiprocessing.Pool() as pool:
             pool.imap_unordered(self._update, ((db, target_id) for db in self.initialized_dbs(conns)))
 
     def test(self, target_id=None):