projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Enable black in tox.ini
[osm/MON.git]
/
osm_mon
/
collector
/
service.py
diff --git
a/osm_mon/collector/service.py
b/osm_mon/collector/service.py
index
314ce11
..
5215e9b
100644
(file)
--- a/
osm_mon/collector/service.py
+++ b/
osm_mon/collector/service.py
@@
-90,7
+90,9
@@
class CollectorService:
vim_type = CollectorService._get_vim_type(conf, vim_account_id)
log.debug("vim type.....{}".format(vim_type))
if vim_type in VIM_COLLECTORS:
vim_type = CollectorService._get_vim_type(conf, vim_account_id)
log.debug("vim type.....{}".format(vim_type))
if vim_type in VIM_COLLECTORS:
- collector = VIM_COLLECTORS[vim_type](conf, vim_account_id, vim_sess_map[vim_account_id])
+ collector = VIM_COLLECTORS[vim_type](
+ conf, vim_account_id, vim_sess_map[vim_account_id]
+ )
metrics = collector.collect(vnfr)
log.debug("Collecting vim metrics.....{}".format(metrics))
else:
metrics = collector.collect(vnfr)
log.debug("Collecting vim metrics.....{}".format(metrics))
else:
@@
-176,7
+178,9
@@
class CollectorService:
# Starting executor pool with pool size process_pool_size. Default process_pool_size is 20
# init_session is called to assign the session map to the gloabal vim session map variable
with concurrent.futures.ProcessPoolExecutor(
# Starting executor pool with pool size process_pool_size. Default process_pool_size is 20
# init_session is called to assign the session map to the gloabal vim session map variable
with concurrent.futures.ProcessPoolExecutor(
- self.conf.get("collector", "process_pool_size"), initializer=init_session, initargs=(vim_sess_map,)
+ self.conf.get("collector", "process_pool_size"),
+ initializer=init_session,
+ initargs=(vim_sess_map,),
) as executor:
log.info(
"Started metric collector process pool with pool size %s"
) as executor:
log.info(
"Started metric collector process pool with pool size %s"