Replace yaml.load by yaml.safe_load
[osm/NBI.git] / osm_nbi / subscriptions.py
index 91d2f2d..b178e5b 100644 (file)
@@ -187,7 +187,6 @@ class SubscriptionThread(threading.Thread):
         self.logger.debug("Starting")
         while not self.to_terminate:
             try:
-
                 self.loop.run_until_complete(
                     asyncio.ensure_future(self.start_kafka(), loop=self.loop)
                 )