This document describes the current stable version of Celery (4.4). For development docs, go here.
celery.utils.nodenames
¶
Worker name utilities.
-
celery.utils.nodenames.
worker_direct
(hostname)[source]¶ Return the
kombu.Queue
being a direct route to a worker.Parameters: hostname (str, Queue) – The fully qualified node name of a worker (e.g., w1@example.com
). If passed akombu.Queue
instance it will simply return that instead.
-
celery.utils.nodenames.
gethostname
() → string¶ Return the current host name.
-
celery.utils.nodenames.
anon_nodename
(hostname=None, prefix='gen')[source]¶ Return the nodename for this process (not a worker).
This is used for e.g. the origin task message field.
-
celery.utils.nodenames.
default_nodename
(hostname)[source]¶ Return the default nodename for this process.
-
celery.utils.nodenames.
node_format
(s, name, **extra)[source]¶ Format worker node name (name@host.com).