From 1d15d534a1f6f83941f8d21aecf5bef350f2d451 Mon Sep 17 00:00:00 2001 From: Anand Doshi Date: Wed, 3 Feb 2016 13:00:31 +0530 Subject: [PATCH] [fix] added async and longjob worker --- bench/templates/supervisor.conf | 10 ++++++++++ bench/utils.py | 2 ++ 2 files changed, 12 insertions(+) diff --git a/bench/templates/supervisor.conf b/bench/templates/supervisor.conf index e97d4aa9..4808123d 100644 --- a/bench/templates/supervisor.conf +++ b/bench/templates/supervisor.conf @@ -27,6 +27,16 @@ user={{ user }} stopwaitsecs=1510 directory={{ sites_dir }} +[program:frappe-async-worker] +command={{ bench_dir }}/env/bin/python -m frappe.celery_app worker -n async@%%h --time-limit 1500 --loglevel INFO +autostart=true +autorestart=true +stdout_logfile={{ bench_dir }}/logs/worker.log +stderr_logfile={{ bench_dir }}/logs/worker.error.log +user={{ user }} +stopwaitsecs=1510 +directory={{ sites_dir }} + [program:frappe-workerbeat] command={{ bench_dir }}/env/bin/python -m frappe.celery_app beat -s beat.schedule autostart=true diff --git a/bench/utils.py b/bench/utils.py index 61d47dc9..df51fe57 100644 --- a/bench/utils.py +++ b/bench/utils.py @@ -120,6 +120,8 @@ def setup_procfile(with_celery_broker=False, with_watch=False, bench='.'): procfile_contents = { 'web': "./env/bin/frappe --serve --sites_path sites", 'worker': "sh -c 'cd sites && exec ../env/bin/python -m frappe.celery_app worker'", + 'longjob_worker': "sh -c 'cd sites && exec ../env/bin/python -m frappe.celery_app -n longjobs@%%h worker'", + 'async_worker': "sh -c 'cd sites && exec ../env/bin/python -m frappe.celery_app -n async@%%h worker'", 'workerbeat': "sh -c 'cd sites && exec ../env/bin/python -m frappe.celery_app beat -s scheduler.schedule'" } if frappe_version > 4: