kopia lustrzana https://github.com/Yakifo/amqtt
Fix missing plugin property
rodzic
080a358dd7
commit
6f586c253c
|
@ -62,7 +62,7 @@ class PluginManager:
|
||||||
for ep in pkg_resources.iter_entry_points(group=namespace):
|
for ep in pkg_resources.iter_entry_points(group=namespace):
|
||||||
plugin = self._load_plugin(ep)
|
plugin = self._load_plugin(ep)
|
||||||
self._plugins.append(plugin)
|
self._plugins.append(plugin)
|
||||||
self.logger.debug(" Plugin %s ready" % plugin.ep.name)
|
self.logger.debug(" Plugin %s ready" % ep.name)
|
||||||
|
|
||||||
def _load_plugin(self, ep: pkg_resources.EntryPoint):
|
def _load_plugin(self, ep: pkg_resources.EntryPoint):
|
||||||
try:
|
try:
|
||||||
|
|
|
@ -60,6 +60,9 @@ class BrokerTest(unittest.TestCase):
|
||||||
asyncio.set_event_loop(self.loop)
|
asyncio.set_event_loop(self.loop)
|
||||||
|
|
||||||
def tearDown(self):
|
def tearDown(self):
|
||||||
|
pending = asyncio.all_tasks(loop=self.loop)
|
||||||
|
self.loop.run_until_complete(asyncio.gather(*pending))
|
||||||
|
|
||||||
self.loop.close()
|
self.loop.close()
|
||||||
|
|
||||||
@patch('hbmqtt.broker.PluginManager')
|
@patch('hbmqtt.broker.PluginManager')
|
||||||
|
|
Ładowanie…
Reference in New Issue