Как я могу загрузить мой проект Django в celery workers ПОСЛЕ их форка?

<

Я использую Django (v3.2.3) и celery (v5.2.3) для проекта. Я заметил, что рабочий и главный процессы используют один и тот же код (вероятно, потому что celery загружает модули моего приложения до того, как форкнет дочерние процессы по причинам конфигурации). Хотя обычно это было бы нормально, я хочу сделать нечто более неразумное :smile: - я хочу, чтобы каждый из рабочих процессов celery загружал код моего проекта после их форка (аналогично тому, как uwsgi делает это с lazy-apps конфигурацией).

< <
  1. listen to the signal worker_process_init (source here)
  2. then use my project's instantiated app ref and talk to the DjangoFixup interface app._fixups[0] here
  3. and try to manually call all the registered signal callbacks for the DjangoFixupWorker here

Любые идеи о том, как заставить это работать, будут очень признательны?

Вернуться на верх