jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ee/connectors/consumer_pool: make the number of workers configurable

Browse source
This commit is contained in:
Amirouche BOUBEKKI 2023-10-31 11:07:22 +01:00
parent 0057553404
commit 144a930193
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ee/connectors/consumer_pool.py
View file

@ -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)