self.logger = logging.getLogger("nbi.subscriptions")
self.aiomain_task = None # asyncio task for receiving kafka bus
self.internal_session = { # used for a session to the engine methods
self.logger = logging.getLogger("nbi.subscriptions")
self.aiomain_task = None # asyncio task for receiving kafka bus
self.internal_session = { # used for a session to the engine methods