diff --git a/jms b/jms
index 4154c5263..1b6935858 100755
--- a/jms
+++ b/jms
@@ -222,7 +222,7 @@ def get_start_celery_default_kwargs():
 
 def get_start_celery_node_tree_kwargs():
     print("\n- Start Celery as Distributed Task Queue: NodeTree")
-    return get_start_worker_kwargs('node_tree', 10)
+    return get_start_worker_kwargs('node_tree', 2)
 
 
 def get_start_celery_check_asset_perm_expired_kwargs():