import getopt
import sys
-from osm_lcm import ns, prometheus, vim_sdn, netslice
+from osm_lcm import ns, vim_sdn, netslice
from osm_lcm.ng_ro import NgRoException, NgRoClient
from osm_lcm.ROclient import ROClient, ROClientException
self.db = Database(config).instance.db
self.fs = Filesystem(config).instance.fs
+ self.fs.sync()
# copy message configuration in order to remove 'group_id' for msg_admin
config_message = config["message"].copy()
# contains created tasks/futures to be able to cancel
self.lcm_tasks = TaskRegistry(self.worker_id, self.logger)
- if self.config.get("tsdb") and self.config["tsdb"].get("driver"):
- if self.config["tsdb"]["driver"] == "prometheus":
- self.prometheus = prometheus.Prometheus(
- self.config["tsdb"], self.worker_id, self.loop
- )
- else:
- raise LcmException(
- "Invalid configuration param '{}' at '[tsdb]':'driver'".format(
- config["tsdb"]["driver"]
- )
- )
- else:
- self.prometheus = None
-
async def check_RO_version(self):
tries = 14
last_error = None
self.loop.run_until_complete(self.check_RO_version())
self.ns = ns.NsLcm(
- self.msg, self.lcm_tasks, self.config, self.loop, self.prometheus
+ self.msg, self.lcm_tasks, self.config, self.loop
)
self.netslice = netslice.NetsliceLcm(
self.msg, self.lcm_tasks, self.config, self.loop, self.ns
self.msg, self.lcm_tasks, self.config, self.loop
)
- # configure tsdb prometheus
- if self.prometheus:
- self.loop.run_until_complete(self.prometheus.start())
-
self.loop.run_until_complete(
asyncio.gather(self.kafka_read(), self.kafka_ping())
)
+
# TODO
# self.logger.debug("Terminating cancelling creation tasks")
# self.lcm_tasks.cancel("ALL", "create")