X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FMON.git;a=blobdiff_plain;f=osm_mon%2Fcollector%2Fvnf_collectors%2Fjuju.py;fp=osm_mon%2Fcollector%2Fvnf_collectors%2Fjuju.py;h=cb924a6e8f02f79c1f087f92b41b5e5abc752962;hp=36aabab23528424489caa74905e09a4cf573b60f;hb=e11d5666a1adfcb2880d99ed16554cdc000507b7;hpb=0ccdba94d5ca1de0ff26c6aaf5a16aacc3c2fd0d diff --git a/osm_mon/collector/vnf_collectors/juju.py b/osm_mon/collector/vnf_collectors/juju.py index 36aabab..cb924a6 100644 --- a/osm_mon/collector/vnf_collectors/juju.py +++ b/osm_mon/collector/vnf_collectors/juju.py @@ -88,7 +88,11 @@ class VCACollector(BaseCollector): day12ops = ops_config.get("day1-2", []) for day12op in day12ops: if day12op and "metrics" in day12op: - vdur = next(filter(lambda vdur: vdur["vdu-id-ref"] == day12op["id"], vnfr["vdur"])) + vdur = next( + filter( + lambda vdur: vdur["vdu-id-ref"] == day12op["id"], vnfr["vdur"] + ) + ) # This avoids errors when vdur records have not been completely filled if vdur and "name" in vdur: @@ -103,14 +107,16 @@ class VCACollector(BaseCollector): log.warning(repr(e)) continue # This avoids errors before application and model is not ready till they are occured - 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( self.n2vc.get_metrics( vca_deployment_info["model"], vca_deployment_info["application"], vca_id=vnfr.get("vca-id"), - ) ) + ) log.debug("Measures: %s", measures) for measure_list in measures.values(): for measure in measure_list: