This document describes the current stable version of Celery (5.2).
For development docs,
go here.
celery.apps.multi
Start/stop/manage workers.
-
class celery.apps.multi.Cluster(nodes, cmd=None, env=None, on_stopping_preamble=None, on_send_signal=None, on_still_waiting_for=None, on_still_waiting_progress=None, on_still_waiting_end=None, on_node_start=None, on_node_restart=None, on_node_shutdown_ok=None, on_node_status=None, on_node_signal=None, on_node_signal_dead=None, on_node_down=None, on_child_spawn=None, on_child_signalled=None, on_child_failure=None)[source]
Represent a cluster of workers.
-
property data
-
find(name)[source]
-
getpids(on_down=None)[source]
-
kill()[source]
-
restart(sig=Signals.SIGTERM)[source]
-
send_all(sig)[source]
-
shutdown_nodes(nodes, sig=Signals.SIGTERM, retry=None)[source]
-
start()[source]
-
start_node(node)[source]
-
stop(retry=None, callback=None, sig=Signals.SIGTERM)[source]
-
stopwait(retry=2, callback=None, sig=Signals.SIGTERM)[source]
-
class celery.apps.multi.Node(name, cmd=None, append=None, options=None, extra_args=None)[source]
Represents a node in a cluster.
-
alive()[source]
-
property argv_with_executable
-
property executable
-
classmethod from_kwargs(name, **kwargs)[source]
-
getopt(*alt)[source]
-
handle_process_exit(retcode, on_signalled=None, on_failure=None)[source]
-
property logfile
-
property pid
-
property pidfile
-
prepare_argv(argv, path)[source]
-
send(sig, on_error=None)[source]
-
start(env=None, **kwargs)[source]
