From 2c9c64a13ff05c5686a5e6ffb2fb7bc6c70213c3 Mon Sep 17 00:00:00 2001 From: fit2bot <68588906+fit2bot@users.noreply.github.com> Date: Mon, 28 Sep 2020 16:19:49 +0800 Subject: [PATCH] =?UTF-8?q?fix(jms):=20=E5=90=AF=E5=8A=A8=E8=84=9A?= =?UTF-8?q?=E6=9C=AC=20task=20=E6=B7=BB=E5=8A=A0=20celery=5Fnode=5Ftree,?= =?UTF-8?q?=20check=5Fasset=5Fperm=5Fexpired=20=E4=B8=A4=E4=B8=AA=20worker?= =?UTF-8?q?=20(#4716)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * fix(jms): 启动脚本 task 添加 celery_node_tree, check_asset_perm_expired 两个 worker * fix: 修改脚本 Co-authored-by: xinwen Co-authored-by: ibuler --- jms | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/jms b/jms index 9c9fa92c3..4154c5263 100755 --- a/jms +++ b/jms @@ -155,21 +155,20 @@ def is_running(s, unlink=True): def parse_service(s): - all_services = [ - 'gunicorn', 'celery_ansible', 'celery_default', - 'beat', 'flower', 'daphne', 'celery_node_tree', - 'check_asset_perm_expired', - ] + web_services = ['gunicorn', 'flower', 'daphne'] + celery_services = ["celery_ansible", "celery_default", "celery_node_tree", "check_asset_perm_expired"] + task_services = celery_services + ['beat'] + all_services = web_services + task_services if s == 'all': return all_services elif s == "web": - return ['gunicorn', 'flower', 'daphne'] + return web_services elif s == 'ws': return ['daphne'] elif s == "task": - return ["celery_ansible", "celery_default", "beat"] + return task_services elif s == "celery": - return ["celery_ansible", "celery_default", "celery_node_tree", "check_asset_perm_expired"] + return celery_services elif "," in s: services = set() for i in s.split(','):