mirror of
https://github.com/wassname/ray.git
synced 2026-06-28 13:54:27 +08:00
Print "Connecting to existing cluster" message to stderr instead of stdout (#10575)
This commit is contained in:
@@ -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:
|
||||
|
||||
Reference in New Issue
Block a user