parent
7e239f229c
commit
9bbd00a49f
@ -144,7 +144,7 @@ class RabitTracker(object):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(
|
def __init__(
|
||||||
self, hostIP, nslave, port=9091, port_end=9999, use_logger: bool = True
|
self, hostIP, nslave, port=9091, port_end=9999, use_logger: bool = False
|
||||||
) -> None:
|
) -> None:
|
||||||
"""A Python implementation of RABIT tracker.
|
"""A Python implementation of RABIT tracker.
|
||||||
|
|
||||||
@ -384,16 +384,17 @@ def start_rabit_tracker(args):
|
|||||||
----------
|
----------
|
||||||
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), nslave=args.num_workers)
|
hostIP=get_host_ip(args.host_ip), nslave=args.num_workers, use_logger=True
|
||||||
|
)
|
||||||
envs.update(rabit.slave_envs())
|
envs.update(rabit.slave_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