From d0f224d5cfd75e497327e09c594f26321076e306 Mon Sep 17 00:00:00 2001
From: Eric Liang <ekhliang@gmail.com>
Date: Wed, 20 Jan 2021 00:29:19 -0800
Subject: [PATCH] Revert "Pipe monitor.err logs to driver" (#13574)

This reverts commit a0d08c2cc638c1766a08e2030642c9b434609efa.
---
 python/ray/log_monitor.py | 4 ++--
 python/ray/worker.py      | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/python/ray/log_monitor.py b/python/ray/log_monitor.py
index cc5fee5f7..c4e2ca1d2 100644
--- a/python/ray/log_monitor.py
+++ b/python/ray/log_monitor.py
@@ -125,8 +125,8 @@ class LogMonitor:
         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
index a318d114e..350bbc649 100644
--- a/python/ray/worker.py
+++ b/python/ray/worker.py
@@ -995,7 +995,7 @@ def print_worker_logs(data: Dict[str, str], print_file: Any):
         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: