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)[исходный код]¶

Represent a cluster of workers.

property data¶

find(name)[исходный код]¶

getpids(on_down=None)[исходный код]¶

kill()[исходный код]¶

restart(sig=Signals.SIGTERM)[исходный код]¶

send_all(sig)[исходный код]¶

shutdown_nodes(nodes, sig=Signals.SIGTERM, retry=None)[исходный код]¶

start()[исходный код]¶

start_node(node)[исходный код]¶

stop(retry=None, callback=None, sig=Signals.SIGTERM)[исходный код]¶

stopwait(retry=2, callback=None, sig=Signals.SIGTERM)[исходный код]¶

class celery.apps.multi.Node(name, cmd=None, append=None, options=None, extra_args=None)[исходный код]¶

Represents a node in a cluster.

alive()[исходный код]¶

property argv_with_executable¶

property executable¶

classmethod from_kwargs(name, **kwargs)[исходный код]¶

getopt(*alt)[исходный код]¶

handle_process_exit(retcode, on_signalled=None, on_failure=None)[исходный код]¶

property logfile¶

property pid¶

property pidfile¶

prepare_argv(argv, path)[исходный код]¶

send(sig, on_error=None)[исходный код]¶

start(env=None, **kwargs)[исходный код]¶