apps.multi

Start/stop/manage workers.

Module Contents

Classes

NamespacedOptionParser(self,args)
Node(self,name,cmd=None,append=None,options=None,extra_args=None) Represents a node in a cluster.
MultiParser(self,cmd=”celery worker”,append=”“,prefix=”“,suffix=”“,range_prefix=”celery”)
Cluster(self,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.

Functions

celery_exe(*args)
build_nodename(name,prefix,suffix)
build_expander(nodename,shortname,hostname)
format_opt(opt,value)
_kwargs_to_command_line(kwargs)
maybe_call(fun,*args,**kwargs)
celery_exe(*args)
build_nodename(name, prefix, suffix)
build_expander(nodename, shortname, hostname)
format_opt(opt, value)
_kwargs_to_command_line(kwargs)
class NamespacedOptionParser(args)
__init__(args)
parse()
process_long_opt(arg, value=None)
process_short_opt(arg, value=None)
optmerge(ns, defaults=None)
add_option(name, value, short=False, ns=None)
class Node(name, cmd=None, append=None, options=None, extra_args=None)

Represents a node in a cluster.

__init__(name, cmd=None, append=None, options=None, extra_args=None)
_annotate_with_default_opts(options)
_setdefaultopt(d, alt, value)
_prepare_expander()
_prepare_argv()
alive()
send(sig, on_error=None)
start(env=None, **kwargs)
_waitexec(argv, path=None, env=None, on_spawn=None, on_signalled=None, on_failure=None)
handle_process_exit(retcode, on_signalled=None, on_failure=None)
prepare_argv(argv, path)
getopt(*alt)
__repr__()
pidfile()
logfile()
pid()
pid(value)
executable()
argv_with_executable()
from_kwargs(name, **kwargs)
maybe_call(fun, *args, **kwargs)
class MultiParser(cmd="celery worker", append="", prefix="", suffix="", range_prefix="celery")
__init__(cmd="celery worker", append="", prefix="", suffix="", range_prefix="celery")
parse(p)
_node_from_options(p, name, prefix, suffix, cmd, append, options)
_get_ranges(names)
_update_ns_opts(p, names)
_update_ns_ranges(p, ranges)
_parse_ns_range(ns, ranges=False)
class 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.

__init__(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)
start()
start_node(node)
_start_node(node)
send_all(sig)
kill()
restart(sig=None)
stop(retry=None, callback=None, sig=None)
stopwait(retry=2, callback=None, sig=None)
_stop_nodes(retry=None, on_down=None, sig=None)
shutdown_nodes(nodes, sig=None, retry=None)
find(name)
getpids(on_down=None)
__repr__()
data()