This document describes the current stable version of Celery (4.0).
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.
-
data
-
find
(name)[source]
-
getpids
(on_down=None)[source]
-
kill
()[source]
-
restart
(sig=15)[source]
-
send_all
(sig)[source]
-
shutdown_nodes
(nodes, sig=15, retry=None)[source]
-
start
()[source]
-
start_node
(node)[source]
-
stop
(retry=None, callback=None, sig=15)[source]
-
stopwait
(retry=2, callback=None, sig=15)[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]
-
argv_with_executable
[source]
-
executable
[source]
-
classmethod
from_kwargs
(name, **kwargs)[source]
-
getopt
(*alt)[source]
-
handle_process_exit
(retcode, on_signalled=None, on_failure=None)[source]
-
logfile
[source]
-
pid
-
pidfile
[source]
-
prepare_argv
(argv, path)[source]
-
send
(sig, on_error=None)[source]
-
start
(env=None, **kwargs)[source]