accounting/bench
2
0
Fork 0
mirror of https://github.com/frappe/bench.git synced 2025-01-10 17:24:41 +00:00
Code Issues Releases Activity

feat: added option to provide custom queues

Browse Source
This commit is contained in:
Francisco Roldan 2021-08-30 12:35:53 -03:00
parent d467cf54c1
commit e12f53d1a5
2 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
bench/config/supervisor.py
View File

@ -42,6 +42,7 @@ def generate_supervisor_config(bench_path, user=None, yes=False, skip_redis=Fals
"background_workers": config.get('background_workers') or 1,
"bench_cmd": which('bench'),
"skip_redis": skip_redis,
"custom_queues": config.get("custom_queues", {}),
})
conf_path = os.path.join(bench_path, 'config', 'supervisor.conf')

16
bench/config/templates/supervisor.conf
View File

@ -65,6 +65,22 @@ killasgroup=true
numprocs={{ background_workers }}
process_name=%(program_name)s-%(process_num)d
{% for queue_name, queue_details in custom_queues.items() %}
[program:{{ bench_name }}-frappe-{{ queue_name }}-worker]
command={{ bench_cmd }} worker --queue {{ queue_name }}
priority=4
autostart=true
autorestart=true
stdout_logfile={{ bench_dir }}/logs/worker.log
stderr_logfile={{ bench_dir }}/logs/worker.error.log
user={{ user }}
stopwaitsecs={{ queue_details["timeout"] }}
directory={{ bench_dir }}
killasgroup=true
numprocs={{ queue_details["workers"] or background_workers }}
process_name=%(program_name)s-%(process_num)d
{% endfor %}
{% else %}
[program:{{ bench_name }}-frappe-workerbeat]
command={{ bench_dir }}/env/bin/python -m frappe.celery_app beat -s beat.schedule