Don't use multiprocessing when having one process

This commit is contained in:
Markus Unterwaditzer 2014-04-19 23:59:35 +02:00
parent f8c2c8f879
commit 6c81fd6fc2

View file

@ -201,9 +201,19 @@ def _main(env, file_cfg):
'general': general
})
from multiprocessing import Pool
p = Pool(processes=general.get('processes', 0) or len(actions))
p.map(_sync_collection, actions)
processes = general.get('processes', 0) or len(actions)
cli_logger.debug('Using {} processes.'.format(processes))
if processes == 1:
cli_logger.debug('Not using multiprocessing.')
_map = map
else:
cli_logger.debug('Using multiprocessing.')
from multiprocessing import Pool
p = Pool(processes=general.get('processes', 0) or len(actions))
_map = p.map
_map(_sync_collection, actions)
app.register_command('sync', sync_command)
app()