This document describes the current stable version of Celery (5.2). For development docs, go here.

celery.concurrency.prefork

Prefork execution pool.

Pool implementation using multiprocessing.

class celery.concurrency.prefork.TaskPool(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=(), app=None, **options)

Multiprocessing Pool implementation.

BlockingPool

alias of Pool

Pool

alias of AsynPool

did_start_ok()

property num_processes

on_close()

on_start()

on_stop()

Gracefully stop the pool.

on_terminate()

Force terminate the pool.

register_with_event_loop(loop)

restart()

uses_semaphore = True

only used by multiprocessing pool

write_stats = None

celery.concurrency.prefork.process_destructor(pid, exitcode)

Pool child process destructor.

Dispatch the worker_process_shutdown signal.

celery.concurrency.prefork.process_initializer(app, hostname)

Pool child process initializer.

Initialize the child pool process to ensure the correct app instance is used and things like logging works.