Sử dụng nhóm đa xử lý từ tác vụ cần tây làm tăng ngoại lệ

Đây là một vấn đề đã biết với cần tây. Nó bắt nguồn từ một vấn đề được giới thiệu trong sự phụ thuộc của bida. Giải pháp khắc phục là đặt _config theo cách thủ công thuộc tính cho quy trình hiện tại. Cảm ơn người dùng @martinth vì sự cố gắng bên dưới.

from celery.signals import worker_process_init
from multiprocessing import current_process

@worker_process_init.connect
def fix_multiprocessing(**kwargs):
    try:
        current_process()._config
    except AttributeError:
        current_process()._config = {'semprefix': '/mp'}

worker_process_init hook sẽ thực thi mã khi khởi tạo quy trình worker. Chúng tôi chỉ cần kiểm tra xem _config tồn tại và đặt nó nếu nó không tồn tại.