github
/
spug
mirror of https://github.com/openspug/spug
1
0
Fork 0
Code Issues Releases Wiki Activity

fix issue

pull/365/head
vapao 2021-07-07 09:02:50 +08:00
parent 1a24fac661
commit 5fda8cfc73
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spug_api/apps/deploy/utils.py
View File

@ -105,7 +105,7 @@ def _ext1_deploy(req, helper, env):
helper.local(f'cd {REPOS_DIR} && tar zcf {env.SPUG_VERSION}.tar.gz {exclude} {contain}') helper.local(f'cd {REPOS_DIR} && tar zcf {env.SPUG_VERSION}.tar.gz {exclude} {contain}')
helper.send_step('local', 6, f'完成') helper.send_step('local', 6, f'完成')
threads, latest_exception = [], None threads, latest_exception = [], None
with futures.ThreadPoolExecutor(max_workers=min(10, os.cpu_count() + 5)) as executor: with futures.ThreadPoolExecutor(max_workers=max(10, os.cpu_count() + 5)) as executor:
for h_id in json.loads(req.host_ids): for h_id in json.loads(req.host_ids):
env = AttrDict(env.items()) env = AttrDict(env.items())
t = executor.submit(_deploy_ext1_host, helper, h_id, extend, env) t = executor.submit(_deploy_ext1_host, helper, h_id, extend, env)
@ -168,7 +168,7 @@ def _ext2_deploy(req, helper, env):
break break
if host_actions: if host_actions:
threads, latest_exception = [], None threads, latest_exception = [], None
with futures.ThreadPoolExecutor(max_workers=min(10, os.cpu_count() + 5)) as executor: with futures.ThreadPoolExecutor(max_workers=max(10, os.cpu_count() + 5)) as executor:
for h_id in json.loads(req.host_ids): for h_id in json.loads(req.host_ids):
env = AttrDict(env.items()) env = AttrDict(env.items())
t = executor.submit(_deploy_ext2_host, helper, h_id, host_actions, env) t = executor.submit(_deploy_ext2_host, helper, h_id, host_actions, env)