commit d124bfe3d2ac63a95fd2af44db3184985ab74d75
author kuuse <johan.kuuse@altran.com> Tue Jun 18 12:09:24 2019 +0200
committer kuuse <johan.kuuse@altran.com> Mon Jul 01 15:02:30 2019 +0200
tree 82c55f2c0f16e7f8c20393e1db4c130031e0ef2a
parent 29cfa602d40ff4d3e7f611414cf66d4cc62a2be6

Prepare LCM tasks for HA

Change-Id: I6146d5903e95d6d710d349a08fcf5ae03127dfed
Signed-off-by: kuuse <johan.kuuse@altran.com>

osm_lcm/lcm.py

diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index 8f66055..27a44cb 100644
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -71,8 +71,6 @@
         self.consecutive_errors = 0
         self.first_start = False
 
-        # contains created tasks/futures to be able to cancel
-        self.lcm_tasks = TaskRegistry()
         # logging
         self.logger = logging.getLogger('lcm')
         # get id
@@ -174,6 +172,9 @@
             self.logger.critical(str(e), exc_info=True)
             raise LcmException(str(e))
 
+        # contains created tasks/futures to be able to cancel
+        self.lcm_tasks = TaskRegistry(self.worker_id, self.db, self.logger)
+
         self.ns = ns.NsLcm(self.db, self.msg, self.fs, self.lcm_tasks, self.ro_config, self.vca_config, self.loop)
         self.netslice = netslice.NetsliceLcm(self.db, self.msg, self.fs, self.lcm_tasks, self.ro_config, 
                                              self.vca_config, self.loop)