Wie füge ich dem aktuellen Multiprocessing-Pool aus einer Aufgabe heraus weitere Threads hinzu (und entferne Threads) (d. h. celeryd wurde mit CELERYD_CONCURRENCY = 10 ausgeführt, aber ich möchte es on-the-fly auf CELERYD_CONCURRENCY = 15 ändern)?
Es gibt eine Funktion namens celery.concurrency.processes.TaskPool.Pool.grow aber ich habe keine Ahnung, wie ich diese Funktion aus einer laufenden Aufgabe heraus aufrufen kann oder ob es die richtige Funktion dafür ist.