diff --git a/fleetrec/core/engine/local_engine.py b/fleetrec/core/engine/local_engine.py index 1610c530fddffb4bd0e9c74dacf516591aa1e099..c7d06a1fe09cce569670b1e35fe4a4cbdc3f4834 100644 --- a/fleetrec/core/engine/local_engine.py +++ b/fleetrec/core/engine/local_engine.py @@ -84,12 +84,11 @@ def start_procs(args, yaml): if len(log_fns) > 0: log_fns[i].close() - print("all workers exit, going to finish parameter server", file=sys.stderr) for i in range(server_num): if len(log_fns) > 0: log_fns[i].close() procs[i].terminate() - print("all parameter server are killed", file=sys.stderr) + print("all workers and parameter servers already completed", file=sys.stderr) class Launch: