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

F 修复某些错误未能正常反馈到发布详情页的问题

pull/59/head
vapao 2020-04-03 12:50:55 +08:00
parent 3c3889b8e5
commit 11235bb07c
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -91,8 +91,10 @@ def _ext1_deploy(req, helper, env):
for h_id in json.loads(req.host_ids): for h_id in json.loads(req.host_ids):
threads.append(executor.submit(_deploy_ext1_host, helper, h_id, extend, env)) threads.append(executor.submit(_deploy_ext1_host, helper, h_id, extend, env))
for t in futures.as_completed(threads): for t in futures.as_completed(threads):
if t.exception(): exception = t.exception()
raise t.exception() if exception:
helper.send_error(h_id, f'Exception: {exception}')
raise exception
def _ext2_deploy(req, helper, env): def _ext2_deploy(req, helper, env):
@ -114,8 +116,10 @@ def _ext2_deploy(req, helper, env):
for h_id in json.loads(req.host_ids): for h_id in json.loads(req.host_ids):
threads.append(executor.submit(_deploy_ext2_host, helper, h_id, host_actions, env)) threads.append(executor.submit(_deploy_ext2_host, helper, h_id, host_actions, env))
for t in futures.as_completed(threads): for t in futures.as_completed(threads):
if t.exception(): exception = t.exception()
raise t.exception() if exception:
helper.send_error(h_id, f'Exception: {exception}')
raise exception
def _deploy_ext1_host(helper, h_id, extend, env): def _deploy_ext1_host(helper, h_id, extend, env):