ENH: log when worker started

xinference/core/service.py

@@ -175,6 +175,7 @@ async def add_worker(self, worker_address: str):
 
         worker_ref = await xo.actor_ref(address=worker_address, uid=WorkerActor.uid())
         self._worker_address_to_worker[worker_address] = worker_ref
+        logger.info("Worker %s has been added successfully", worker_address)
 
     async def report_worker_status(
         self, worker_address: str, status: Dict[str, ResourceStatus]

xinference/deploy/supervisor.py

@@ -63,7 +63,7 @@ async def start_supervisor_components(address: str, host: str, port: int):
     )
     await restful_actor.serve()
     url = f"http://{host}:{port}"
-    logger.info(f"Server address: {url}")
+    logger.info(f"Xinference successfully started. Endpoint: {url}")
     return url
 
 

xinference/deploy/worker.py

@@ -13,12 +13,15 @@
 # limitations under the License.
 
 import asyncio
+import logging
 from typing import Dict, Optional
 
 import xoscar as xo
 
 from ..core.service import WorkerActor
 
+logger = logging.getLogger(__name__)
+
 
 async def start_worker_components(address: str, supervisor_address: str):
     actor_pool_config = await xo.get_pool_config(address)
@@ -35,6 +38,7 @@ async def start_worker_components(address: str, supervisor_address: str):
         supervisor_address=supervisor_address,
         subpool_addresses=subpool_addresses,  # exclude the main actor pool.
     )
+    logger.info(f"Xinference worker successfully started.")
 
 
 async def _start_worker(