Revert "Pipe monitor.err logs to driver" (ray-project#13574)

This reverts commit a0d08c2.
erikerlandson · Jan 20, 2021 · d0f224d · d0f224d
1 parent b2a6e55
commit d0f224d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/python/ray/log_monitor.py b/python/ray/log_monitor.py
@@ -125,8 +125,8 @@ def update_log_filenames(self):
         log_file_paths = glob.glob(f"{self.logs_dir}/worker*[.out|.err]")
         # segfaults and other serious errors are logged here
         raylet_err_paths = glob.glob(f"{self.logs_dir}/raylet*.err")
-        # The .log file contains autoscaler events, the .err file errors.
-        monitor_log_paths = glob.glob(f"{self.logs_dir}/monitor*[.log|.err]")
+        # monitor logs are needed to report autoscaler events
+        monitor_log_paths = glob.glob(f"{self.logs_dir}/monitor.log")
         # If gcs server restarts, there can be multiple log files.
         gcs_err_path = glob.glob(f"{self.logs_dir}/gcs_server*.err")
         for file_path in (log_file_paths + raylet_err_paths + gcs_err_path +

diff --git a/python/ray/worker.py b/python/ray/worker.py
@@ -995,7 +995,7 @@ def color_for(data: Dict[str, str]) -> str:
         else:
             return colorama.Fore.CYAN
 
-    if data["pid"] == "autoscaler" and not data["is_err"]:
+    if data["pid"] == "autoscaler":
         pid = "{} +{}".format(data["pid"], time_string())
         lines = filter_autoscaler_events(data["lines"])
     else: