セロリタスクからマルチプロセッシングプールを使用すると、例外が発生します

これはセロリの既知の問題です。これは、ビリヤードの依存関係で導入された問題に起因します。回避策は、_configを手動で設定することです。 現在のプロセスの属性。以下の回避策を提供してくれたユーザー@martinthに感謝します。

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 フックは、ワーカープロセスの初期化時にコードを実行します。 _configかどうかを確認するだけです。 存在し、存在しない場合は設定します。