Ivan Shevchenko

but when I run it without celery just like: ``` @manager.command def mqtt_test(): while True: sleep(1) res = mqtt.client.publish('clients/c/0000000016ab8294', json.dumps({"celery":"ok"}), qos=2) res.wait_for_publish() ``` No issues here

this is also related current issue: https://stackoverflow.com/questions/55864502/mqtt-message-not-getting-published-from-celery-beat-task