Set use_logger in tracker to false. (#7438)
This commit is contained in:
parent
d4274bc556
commit
e27f543deb
@ -162,7 +162,7 @@ class RabitTracker:
|
|||||||
n_workers: int,
|
n_workers: int,
|
||||||
port: int = 9091,
|
port: int = 9091,
|
||||||
port_end: int = 9999,
|
port_end: int = 9999,
|
||||||
use_logger: bool = True,
|
use_logger: bool = False,
|
||||||
) -> None:
|
) -> None:
|
||||||
"""A Python implementation of RABIT tracker.
|
"""A Python implementation of RABIT tracker.
|
||||||
|
|
||||||
@ -407,16 +407,17 @@ def start_rabit_tracker(args: argparse.Namespace) -> None:
|
|||||||
----------
|
----------
|
||||||
args: arguments to start the rabit tracker.
|
args: arguments to start the rabit tracker.
|
||||||
"""
|
"""
|
||||||
envs = {'DMLC_NUM_WORKER': args.num_workers,
|
envs = {"DMLC_NUM_WORKER": args.num_workers, "DMLC_NUM_SERVER": args.num_servers}
|
||||||
'DMLC_NUM_SERVER': args.num_servers}
|
rabit = RabitTracker(
|
||||||
rabit = RabitTracker(hostIP=get_host_ip(args.host_ip), n_workers=args.num_workers)
|
hostIP=get_host_ip(args.host_ip), n_workers=args.num_workers, use_logger=True
|
||||||
|
)
|
||||||
envs.update(rabit.worker_envs())
|
envs.update(rabit.worker_envs())
|
||||||
rabit.start(args.num_workers)
|
rabit.start(args.num_workers)
|
||||||
sys.stdout.write('DMLC_TRACKER_ENV_START\n')
|
sys.stdout.write("DMLC_TRACKER_ENV_START\n")
|
||||||
# simply write configuration to stdout
|
# simply write configuration to stdout
|
||||||
for k, v in envs.items():
|
for k, v in envs.items():
|
||||||
sys.stdout.write(f"{k}={v}\n")
|
sys.stdout.write(f"{k}={v}\n")
|
||||||
sys.stdout.write('DMLC_TRACKER_ENV_END\n')
|
sys.stdout.write("DMLC_TRACKER_ENV_END\n")
|
||||||
sys.stdout.flush()
|
sys.stdout.flush()
|
||||||
rabit.join()
|
rabit.join()
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user