U Z+d* @sdZddlZddlZddlmZddlmZmZddlm Z ddl m Z edZ d Z d Zd Ze ded ejZd ZddZddZd"ddZddZddZddZd#ddZeeddZd$d d!ZdS)%zWorker name utilities.N)partial)ExchangeQueue)memoize) simple_formatzC.dq2z{hostname}.dq2@Zcelery)Cache) worker_direct gethostnamenodename anon_nodename nodesplitdefault_nodename node_format host_formatcCs"t|tr|Sttj|dt|S)a5Return the :class:`kombu.Queue` being a direct route to a worker. Arguments: hostname (str, ~kombu.Queue): The fully qualified node name of a worker (e.g., ``w1@example.com``). If passed a :class:`kombu.Queue` instance it will simply return that instead. hostname) isinstancerWORKER_DIRECT_QUEUE_FORMATformatWORKER_DIRECT_EXCHANGErr:/tmp/pip-unpacked-wheel-ucduq0nd/celery/utils/nodenames.pyr s  r cCst||fS)z)Create node name from name/hostname pair.) NODENAME_SEPjoin)namerrrrr 1sr gencCs"td|ttg|ptS)zsReturn the nodename for this process (not a worker). This is used for e.g. the origin task message field. )r rstrosgetpidr )rprefixrrrr 6sr cCs(|td}t|dkr$d|dfS|S)z,Split node name into tuple of name/hostname.rNr)splitrlen)rpartsrrrr?s   rcCs$t|pd\}}t|pt|p tS)z-Return the default nodename for this process.r)rr NODENAME_DEFAULTr )rrhostrrrrGsrcKs(t|\}}t|||ptfd|i|S)z(Format worker node name (name@host.com).p)rrr&)srextra shortnamer'rrrrMs rr0cCs&ddlm}|}|r"||S|S)Nr)current_process_index)logr-)r"defaultr-indexrrr_fmt_process_indexTs r1-cKsD|pt}|d\}}}|p |}t|||ttdf|}t||S)zFormat host %x abbreviations..)hndiI)r partitiondictr1_fmt_process_index_with_prefixr)r)r'rr*hname_domainkeysrrrr]s r)Nr)rr,)NN)__doc__r socket functoolsrZ kombu.entityrrZ functionalrtextrrrrr&r:r __all__r r r rrrr1r;rrrrrs*