diff --git a/profit/run/default.py b/profit/run/default.py index fb379b70..ff16a6ff 100644 --- a/profit/run/default.py +++ b/profit/run/default.py @@ -86,12 +86,12 @@ def check_runs(self, poll=False): def handle_config(cls, config, base_config): """ class: local - parallel: 1 # maximum number of simultaneous runs (for spawn array) + parallel: all # maximum number of simultaneous runs (for spawn array) sleep: 0 # number of seconds to sleep while polling fork: true # whether to spawn the (non-custom) worker via forking instead of a subprocess (via a shell) """ - if 'parallel' not in config: - config['parallel'] = 1 + if 'parallel' not in config or config['parallel'] == 'all': + config['parallel'] = os.cpu_count() if 'sleep' not in config: config['sleep'] = 0 if 'fork' not in config: