from kombu import Connection
from tapiriik.settings import RABBITMQ_BROKER_URL
mq = Connection(RABBITMQ_BROKER_URL)
mq.connect()
from kombu import Connection
from tapiriik.settings import RABBITMQ_BROKER_URL
mq = Connection(RABBITMQ_BROKER_URL, transport_options={'confirm_publish': True})
mq.connect()

Enable MQ publish confirmations for scheduler