X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FNBI.git;a=blobdiff_plain;f=osm_nbi%2Fsubscriptions.py;fp=osm_nbi%2Fsubscriptions.py;h=b178e5bae8dc8b5c89a1bf639e8f84c5c317eaa9;hp=91d2f2d1954f3af9902388d4dc3778f0019184d4;hb=4cd875d2a38488b5e717258d548eeb8e557ec9a8;hpb=f2af4a100d308e07f355d61b94fb27d1ccc97aa2 diff --git a/osm_nbi/subscriptions.py b/osm_nbi/subscriptions.py index 91d2f2d..b178e5b 100644 --- a/osm_nbi/subscriptions.py +++ b/osm_nbi/subscriptions.py @@ -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) )