Process Supervisor - celery.supervisor¶

class celery.supervisor.OFASupervisor(target, args=None, kwargs=None, ping_timeout=30, join_timeout=2, max_restart_freq=3, max_restart_freq_time=10, check_interval=2)¶

Process supervisor using the one_for_all strategy.

However, instead of registering a list of processes, you have one process which runs a pool. Makes for an easy implementation.

Parameters:	target – see target. args – see args. kwargs – see kwargs. join_timeout – see join_timeout. max_restart_freq – see max_restart_freq. max_restart_freq_time – see max_restart_freq_time. check_interval – see max_restart_freq_time.

target¶

The target callable to be launched in a new process.

args¶

The positional arguments to apply to target.

kwargs¶

The keyword arguments to apply to target.

join_timeout¶

If the process is dead, try to give it a few seconds to join.

max_restart_freq¶

Limit the number of restarts which can occur in a given time interval.

The max restart frequency is the number of restarts that can occur within the interval max_restart_freq_time.

The restart mechanism prevents situations where the process repeatedly dies for the same reason. If this happens both the process and the supervisor is terminated.

max_restart_freq_time¶

See max_restart_freq.

check_interval¶

The time in seconds, between process pings.

start()¶

Launches the target in a seperate process and starts supervising it.

celery.supervisor.raise_ping_timeout(msg)¶

Raises multiprocessing.TimeoutError, for use in threading.Timer callbacks.