X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=lcm%2Fosm_lcm%2Flcm.py;fp=lcm%2Fosm_lcm%2Flcm.py;h=aa90f3d85bb7a67f8becaa900aa1cabe63f2d8a8;hb=0b68f8a2b982a9c1990d24acc07f8738f2bb24bb;hp=2b62c1f4fd5bf4ef0016b756b900a40ff7837a0e;hpb=54467bb7f4edec1fa4fe195fe4ccf34fea5d7f9e;p=osm%2FRO.git

diff --git a/lcm/osm_lcm/lcm.py b/lcm/osm_lcm/lcm.py
index 2b62c1f4..aa90f3d8 100644
--- a/lcm/osm_lcm/lcm.py
+++ b/lcm/osm_lcm/lcm.py
@@ -1044,7 +1044,13 @@ class Lcm:
                     self.logger.error("Task Kafka Exception {}".format(e))
                     await asyncio.sleep(1, loop=self.loop)
         self.logger.debug("Task Kafka terminating")
+        self.logger.debug("Task Kafka exit")
+
+    def start(self):
+        self.loop = asyncio.get_event_loop()
+        self.loop.run_until_complete(self.read_kafka())
         # TODO
+        # self.logger.debug("Terminating cancelling creation tasks")
         # self.cancel_tasks("ALL", "create")
         # timeout = 200
         # while self.is_pending_tasks():
@@ -1053,11 +1059,6 @@ class Lcm:
         #     timeout -= 2
         #     if not timeout:
         #         self.cancel_tasks("ALL", "ALL")
-        self.logger.debug("Task Kafka exit")
-
-    def start(self):
-        self.loop = asyncio.get_event_loop()
-        self.loop.run_until_complete(self.read_kafka())
         self.loop.close()
         self.loop = None
         if self.db: