diff --git a/python/ray/worker.py b/python/ray/worker.py index 1bc328216..af9285989 100644 --- a/python/ray/worker.py +++ b/python/ray/worker.py @@ -622,13 +622,16 @@ def init( if address: redis_address, _, _ = services.validate_redis_address(address) - print("Connecting to existing Ray cluster at address:", redis_address) else: redis_address = None if configure_logging: setup_logger(logging_level, logging_format) + if redis_address is not None: + logger.info( + f"Connecting to existing Ray cluster at address: {redis_address}") + if local_mode: driver_mode = LOCAL_MODE else: