Выход SocketIO из асинхронного работника Celery не работает

Я использую Flask-SocketIO для создания системы уведомлений в реальном времени. Существует внешний сервер API, который вызывает сервер socketio в отдельном потоке через RPC. Метод, вызываемый RPC, создает задачу Celery, которая при использовании вызывает метод, вызывающий socketio.emit(). Однако сообщение, похоже, на самом деле не отправляется, поскольку в клиенте javascript сообщение не получено. Мой инстинкт подсказывает мне, что, поскольку рабочий процесс Celery выполняется в отдельном процессе, вызываемый метод socketio.emit() не отправляет подключенному клиенту, хотя объекты существуют в одном и том же месте в памяти. На сервере работает gevent, а Celery получает и выполняет задачи, как видно из журналов. Кроме того, я проверил, что socketio.emit() вызывается работником Celery, и я проверил, что когда задача вызывается напрямую, минуя Celery, socketio работает должным образом. Любые идеи о том, как заставить socketio правильно общаться, когда на него ссылается задача сельдерея в отдельном процессе?