accounting/bench
2
0
Fork 0
mirror of https://github.com/frappe/bench.git synced 2025-01-09 00:21:23 +00:00
Code Issues Releases Activity

Merge pull request #1507 from akhilnarang/optimize-restart

Browse Source 
feat(supervisor): restart each group separately
This commit is contained in:
Ankush Menat 2024-01-10 23:05:57 +05:30 committed by GitHub
commit 0056cdf310
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
bench/utils/bench.py
View File

@ -310,22 +310,23 @@ def restart_supervisor_processes(bench_path=".", web_workers=False, _raise=False
supervisor_status = get_cmd_output("sudo supervisorctl status", cwd=bench_path) supervisor_status = get_cmd_output("sudo supervisorctl status", cwd=bench_path)
if web_workers and f"{bench_name}-web:" in supervisor_status: if web_workers and f"{bench_name}-web:" in supervisor_status:
group = f"{bench_name}-web:\t" groups = [f"{bench_name}-web:\t"]
elif f"{bench_name}-workers:" in supervisor_status: elif f"{bench_name}-workers:" in supervisor_status:
group = f"{bench_name}-workers: {bench_name}-web:" groups = [f"{bench_name}-web:", f"{bench_name}-workers:"]
# backward compatibility # backward compatibility
elif f"{bench_name}-processes:" in supervisor_status: elif f"{bench_name}-processes:" in supervisor_status:
group = f"{bench_name}-processes:" groups = [f"{bench_name}-processes:"]
# backward compatibility # backward compatibility
else: else:
group = "frappe:" groups = ["frappe:"]
failure = bench.run(f"{sudo}supervisorctl restart {group}", _raise=_raise) for group in groups:
if failure: failure = bench.run(f"{sudo}supervisorctl restart {group}", _raise=_raise)
log("restarting supervisor failed. Use `bench restart` to retry.", level=3) if failure:
log(f"restarting supervisor group `{group}` failed. Use `bench restart` to retry.", level=3)
def restart_systemd_processes(bench_path=".", web_workers=False, _raise=True): def restart_systemd_processes(bench_path=".", web_workers=False, _raise=True):