Jochen Kienzle <jochen.kien...@bosch.io> added the comment:

Thanks for your reply.

I already tried 

----------------------------
asyncio.run(self.mqtt_client.publish_json(INGESTION_TOPIC, msg))
----------------------------

but this leads (rarely) to the following error:

----------------------------
got Future <Future pending> attached to a different loop
----------------------------

I want to point out that asyncio.run() was called in a thread without an event 
loop.

So, it seems to be that the issue is either on asyncio or on hbmqtt.client side 
(loop handling).

Any opinions, ideas or hints?

----------

_______________________________________
Python tracker <rep...@bugs.python.org>
<https://bugs.python.org/issue42445>
_______________________________________
_______________________________________________
Python-bugs-list mailing list
Unsubscribe: 
https://mail.python.org/mailman/options/python-bugs-list/archive%40mail-archive.com

Reply via email to