I’m trying to run a rabbitmq message from inside a celery task. I’m trying to notify another service that the task finished. The weird thing is that if I deactivate .delay() it works perfectly. But, the problem is when I combine celery task delayed with pika BlockingConnection. You will see that I initialiced my send_message function in a different thread