diff --git a/analytics/analytics/analytic_unit_manager.py b/analytics/analytics/analytic_unit_manager.py index 64b9f27..7167a7e 100644 --- a/analytics/analytics/analytic_unit_manager.py +++ b/analytics/analytics/analytic_unit_manager.py @@ -11,7 +11,6 @@ from models import ModelCache logger = log.getLogger('AnalyticUnitManager') -WORKERS_EXECUTORS = 20 AnalyticUnitId = str @@ -43,7 +42,7 @@ class AnalyticUnitManager: def __init__(self): self.analytic_workers: Dict[AnalyticUnitId, AnalyticUnitWorker] = dict() - self.workers_executor = ThreadPoolExecutor(max_workers=WORKERS_EXECUTORS) + self.workers_executor = ThreadPoolExecutor() def __ensure_worker( self,