|
|
@ -11,7 +11,6 @@ from models import ModelCache |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
logger = log.getLogger('AnalyticUnitManager') |
|
|
|
logger = log.getLogger('AnalyticUnitManager') |
|
|
|
WORKERS_EXECUTORS = 20 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
AnalyticUnitId = str |
|
|
|
AnalyticUnitId = str |
|
|
|
|
|
|
|
|
|
|
@ -43,7 +42,7 @@ class AnalyticUnitManager: |
|
|
|
|
|
|
|
|
|
|
|
def __init__(self): |
|
|
|
def __init__(self): |
|
|
|
self.analytic_workers: Dict[AnalyticUnitId, AnalyticUnitWorker] = dict() |
|
|
|
self.analytic_workers: Dict[AnalyticUnitId, AnalyticUnitWorker] = dict() |
|
|
|
self.workers_executor = ThreadPoolExecutor(max_workers=WORKERS_EXECUTORS) |
|
|
|
self.workers_executor = ThreadPoolExecutor() |
|
|
|
|
|
|
|
|
|
|
|
def __ensure_worker( |
|
|
|
def __ensure_worker( |
|
|
|
self, |
|
|
|
self, |
|
|
|