From 33f78f7302aaaecce0dc43a548c56c3d8f78cb33 Mon Sep 17 00:00:00 2001
From: yangdsh <dongshen@andrew.cmu.edu>
Date: Tue, 21 Apr 2020 23:28:26 +0000
Subject: [PATCH] pass concurrency option to celery worker

---
 server/website/website/management/commands/startcelery.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/server/website/website/management/commands/startcelery.py b/server/website/website/management/commands/startcelery.py
index 74814f1..5a34ed0 100644
--- a/server/website/website/management/commands/startcelery.py
+++ b/server/website/website/management/commands/startcelery.py
@@ -37,6 +37,12 @@ class Command(BaseCommand):
             default='threads',
             help='Pool implementation: prefork (default), eventlet, gevent, solo or threads.'
                  'Default: threads.')
+        parser.add_argument(
+            '--concurrency',
+            metavar='POOL_CLS',
+            default='4',
+            help='Number of celery tasks that can run in concurrency'
+                 'Default: 4')
         parser.add_argument(
             '--celery-pidfile',
             metavar='PIDFILE',
@@ -95,6 +101,7 @@ class Command(BaseCommand):
         celery_options = [
             '--loglevel={}'.format(loglevel),
             '--pool={}'.format(options['pool']),
+            '--concurrency={}'.format(options['concurrency']),
             '--pidfile={}'.format(options['celery_pidfile']),
         ] + self._parse_suboptions(options['celery_options'])
         celerybeat_options = [