Minor fixes
This commit is contained in:
parent
3fe3139961
commit
aac99a11ba
4 changed files with 8 additions and 4 deletions
|
@ -74,11 +74,12 @@ class MetricsLogging():
|
|||
global EXTENSIVE_LOGGING
|
||||
if EXTENSIVE_LOGGING:
|
||||
if MetricsLogging.is_influx_reachable():
|
||||
EXTENSIVE_LOGGING = False
|
||||
for i in range(CONCURRENCY):
|
||||
worker = threading.Thread(target=MetricsLogging.worker, daemon=True)
|
||||
worker.start()
|
||||
workers.append(worker)
|
||||
else:
|
||||
EXTENSIVE_LOGGING = False
|
||||
|
||||
|
||||
MetricsLogging.start_workers()
|
||||
|
|
Reference in a new issue