projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
OSMENG-1197: Add MON rockcraft.yaml
[osm/MON.git]
/
osm_mon
/
collector
/
vnf_collectors
/
juju.py
diff --git
a/osm_mon/collector/vnf_collectors/juju.py
b/osm_mon/collector/vnf_collectors/juju.py
index
cb924a6
..
fbc6bc2
100644
(file)
--- a/
osm_mon/collector/vnf_collectors/juju.py
+++ b/
osm_mon/collector/vnf_collectors/juju.py
@@
-39,7
+39,6
@@
class VCACollector(BaseCollector):
def __init__(self, config: Config):
super().__init__(config)
self.common_db = CommonDbClient(config)
def __init__(self, config: Config):
super().__init__(config)
self.common_db = CommonDbClient(config)
- self.loop = asyncio.get_event_loop()
# host = config.get("vca", "host")
# port = config.get("vca", "port") if "port" in config.conf["vca"] else 17070
# host = config.get("vca", "host")
# port = config.get("vca", "port") if "port" in config.conf["vca"] else 17070
@@
-60,7
+59,6
@@
class VCACollector(BaseCollector):
db=self.common_db.common_db,
fs=object(),
log=log,
db=self.common_db.common_db,
fs=object(),
log=log,
- loop=self.loop,
on_update_db=None,
)
on_update_db=None,
)
@@
-110,7
+108,7
@@
class VCACollector(BaseCollector):
if vca_deployment_info.get("model") and vca_deployment_info.get(
"application"
):
if vca_deployment_info.get("model") and vca_deployment_info.get(
"application"
):
- measures =
self.loop.run_until_complete
(
+ measures =
asyncio.run
(
self.n2vc.get_metrics(
vca_deployment_info["model"],
vca_deployment_info["application"],
self.n2vc.get_metrics(
vca_deployment_info["model"],
vca_deployment_info["application"],