diff --git a/ee/connectors/consumer_pool.py b/ee/connectors/consumer_pool.py
index b419042bb..5a2dbf34e 100644
--- a/ee/connectors/consumer_pool.py
+++ b/ee/connectors/consumer_pool.py
@@ -10,7 +10,7 @@ def main():
     database_api = DBConnection(DATABASE)
 
     allowed_projects = config('PROJECT_IDS', default=None, cast=Csv(int))
-    w_pool = WorkerPool(n_workers=config('OR_EE_CONNECTOR_WORKER_COUNT'),
+    w_pool = WorkerPool(n_workers=60,
                         project_filter=allowed_projects)
     try:
         w_pool.load_checkpoint(database_api)