From 2e9eb798b95f8a1ac4928616bc76c02ddc46f986 Mon Sep 17 00:00:00 2001
From: Brian Duenas <brian.duenas@ibm.com>
Date: Mon, 12 May 2025 12:20:39 -0700
Subject: [PATCH] expose flag for log stream viewer full logs

Signed-off-by: Brian Duenas <brian.duenas@ibm.com>
---
 app/core/config.py | 1 +
 app/main.py        | 9 ++++++++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/app/core/config.py b/app/core/config.py
index 77ebb4e..b48b3ad 100644
--- a/app/core/config.py
+++ b/app/core/config.py
@@ -23,6 +23,7 @@ class Settings(BaseSettings):
     # server
     ENVIRONMENT: Literal["local", "staging", "production"] = "local"
     API_V1_STR: str = "/api/v1"
+    LOG_STREAM_SEARCH_STRING: str = "Epoch"  # Log viewer search string
     # cluster
     NAMESPACE: str
     # CORS
diff --git a/app/main.py b/app/main.py
index fd749be..f753ccd 100644
--- a/app/main.py
+++ b/app/main.py
@@ -349,7 +349,14 @@ async def stream_job(
     logger.debug(f"Connecting WebSocket for job {job_id}")
     await websocket.accept()
 
-    stream_manager = LogStreamManager(websocket, job_id, full_log, follow, last_lines)
+    stream_manager = LogStreamManager(
+        websocket,
+        job_id,
+        full_log,
+        follow,
+        last_lines,
+        search_string=settings.LOG_STREAM_SEARCH_STRING,
+    )
     try:
         await stream_manager.run()
     except WebSocketDisconnect: