Как получить pid подпроцесса, созданного Process?

Итак, я пытаюсь получить pid подпроцесса, запущенного внутри celery worker.

Проблема в том, что процесс блокируется, и когда я печатаю os.getpid() внутри подпроцесса, я получаю pid рабочего.

Я разрабатываю проект мониторинга для обучения модели nlp с использованием farm-haystack и celery.

p = Process(target=Reader_Training(props)) p.start()

я использую пул потоков для celery . celery -A api worker --loglevel=info --concurrency=3 --max-tasks-per-child=1 -E -P threads

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