IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2024-11-22 08:16:25 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #356 from LibreQoE/fixScheduler2

Browse Source 
Fix scheduler concurrence issues
This commit is contained in:
Robert Chacón 2023-05-18 17:38:44 -06:00 committed by GitHub
commit a306ac16db
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/scheduler.py
View File

@ -12,8 +12,9 @@ if automaticImportUISP:
if automaticImportSplynx: if automaticImportSplynx:
from integrationSplynx import importFromSplynx from integrationSplynx import importFromSplynx
from apscheduler.schedulers.background import BlockingScheduler from apscheduler.schedulers.background import BlockingScheduler
from apscheduler.executors.pool import ThreadPoolExecutor
ads = BlockingScheduler() ads = BlockingScheduler(executors={'default': ThreadPoolExecutor(1)})
def importFromCRM(): def importFromCRM():
if automaticImportUISP: if automaticImportUISP:
@ -48,9 +49,9 @@ def importAndShapePartialReload():
if __name__ == '__main__': if __name__ == '__main__':
importAndShapeFullReload() importAndShapeFullReload()
ads.add_job(importAndShapePartialReload, 'interval', minutes=queueRefreshIntervalMins) ads.add_job(importAndShapePartialReload, 'interval', minutes=queueRefreshIntervalMins, max_instances=1)
if influxDBEnabled: if influxDBEnabled:
ads.add_job(graphHandler, 'interval', seconds=10) ads.add_job(graphHandler, 'interval', seconds=10, max_instances=1)
ads.start() ads.start()