Przeglądaj źródła

[utils] Adds %N abbreviation expanding to the full worker node name

Ask Solem 9 lat temu
rodzic
commit
2c2984e045
1 zmienionych plików z 1 dodań i 1 usunięć
  1. 1 1
      celery/utils/__init__.py

+ 1 - 1
celery/utils/__init__.py

@@ -355,7 +355,7 @@ def default_nodename(hostname):
 def node_format(s, nodename, **extra):
 def node_format(s, nodename, **extra):
     name, host = nodesplit(nodename)
     name, host = nodesplit(nodename)
     return host_format(
     return host_format(
-        s, host, name or NODENAME_DEFAULT, **extra)
+        s, host, name or NODENAME_DEFAULT, N=nodename, **extra)
 
 
 
 
 def _fmt_process_index(prefix='', default='0'):
 def _fmt_process_index(prefix='', default='0'):