log the worker name if set (#6866)

dask · Aug 10, 2022 · f43bc47 · f43bc47
1 parent e1b9e20
commit f43bc47
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -1370,6 +1370,9 @@ async def start_unsafe(self):
 
         logger.info("      Start worker at: %26s", self.address)
         logger.info("         Listening to: %26s", listening_address)
+        if self.name != self.address_safe:
+            # only if name was not None
+            logger.info("          Worker name: %26s", self.name)
         for k, v in self.service_ports.items():
             logger.info("  {:>16} at: {:>26}".format(k, self.ip + ":" + str(v)))
         logger.info("Waiting to connect to: %26s", self.scheduler.address)