Specify stdout or stderr in the scribereader command

Yelp · Feb 23, 2024 · 98eed09 · 98eed09
1 parent 96c9c60
commit 98eed09
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tron/utils/scribereader.py b/tron/utils/scribereader.py
@@ -223,11 +223,11 @@ def read_log_stream_for_action_run(
         location_selector = f"-s {paasta_cluster}"
     truncation_message = (
         [
-            f"This output is truncated. Use this command to view all lines: scribereader {location_selector} {stream_name} --min-date {min_date.date()} --max-date {max_date.date()} | jq --raw-output 'select(.tron_run_number=={int(run_num)}) | .message'"
+            f"This output is truncated. Use this command to view all lines: scribereader {location_selector} {stream_name} --min-date {min_date.date()} --max-date {max_date.date()} | jq --raw-output 'select(.tron_run_number=={int(run_num)} and component == \"{component}\") | .message'"
         ]
         if max_date
         else [
-            f"This output is truncated. Use this command to view all lines: scribereader {location_selector} {stream_name} --min-date {min_date.date()} | jq --raw-output 'select(.tron_run_number=={int(run_num)}) | .message'"
+            f"This output is truncated. Use this command to view all lines: scribereader {location_selector} {stream_name} --min-date {min_date.date()} | jq --raw-output 'select(.tron_run_number=={int(run_num)} and component == \"{component}\") | .message'"
         ]
     )
     truncated = truncation_message if truncated_output else []