From 144a93019371198f8625432a6d38553747917ce6 Mon Sep 17 00:00:00 2001 From: Amirouche BOUBEKKI Date: Tue, 31 Oct 2023 11:07:22 +0100 Subject: [PATCH] ee/connectors/consumer_pool: make the number of workers configurable --- ee/connectors/consumer_pool.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ee/connectors/consumer_pool.py b/ee/connectors/consumer_pool.py index 5a2dbf34e..b419042bb 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=60, + w_pool = WorkerPool(n_workers=config('OR_EE_CONNECTOR_WORKER_COUNT'), project_filter=allowed_projects) try: w_pool.load_checkpoint(database_api)