diff --git a/fleet_rec/core/engine/local_cluster_engine.py b/fleet_rec/core/engine/local_cluster_engine.py index 3bc0bfedfb6e99ca22352e1cef3276211d59b8fd..6b178619f80a4a550adc0e2caa40e0bae48366d7 100644 --- a/fleet_rec/core/engine/local_cluster_engine.py +++ b/fleet_rec/core/engine/local_cluster_engine.py @@ -85,9 +85,8 @@ class LocalClusterEngine(Engine): if len(log_fns) > 0: log_fns[i].close() procs[i].terminate() - print("all workers already completed, you can view logs under the {} directory".format(logs_dir), + print("all workers already completed, you can view logs under the `{}` directory".format(logs_dir), file=sys.stderr) - -def run(self): - self.start_procs() + def run(self): + self.start_procs() diff --git a/fleet_rec/run.py b/fleet_rec/run.py index 41ee2c5996f451ba2a90b2b8681b0ee33b671333..ca0c3ffe6c2f999f01320dcf73713fd4e1cebb9e 100644 --- a/fleet_rec/run.py +++ b/fleet_rec/run.py @@ -174,7 +174,6 @@ def get_abs_model(model): fleet_base = envs.get_runtime_environ("PACKAGE_BASE") workspace_dir = model.split("fleetrec.")[1].replace(".", "/") path = os.path.join(fleet_base, workspace_dir, "config.yaml") - print("use built-in config: {} for model: {}".format(model, path)) else: if not os.path.isfile(model): raise IOError("model config: {} invalid".format(model))