From fe73cad4e865e9c55b6a4403bf428058c9177a5e Mon Sep 17 00:00:00 2001
From: Deep Koluguri <deepkoluguri@gmail.com>
Date: Fri, 22 May 2026 22:35:38 -0400
Subject: [PATCH] feat: add get_alerts query to LabResultWatcherWorkflow

---
 src/curaflow_agent/workflows.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/curaflow_agent/workflows.py b/src/curaflow_agent/workflows.py
index 0bd0164..5ef6dd7 100644
--- a/src/curaflow_agent/workflows.py
+++ b/src/curaflow_agent/workflows.py
@@ -58,6 +58,7 @@ class LabResultWatcherWorkflow:
     def __init__(self) -> None:
         self._pending_lab_results = []
         self._is_discharged = False
+        self._alerts = []
 
     @workflow.signal
     def add_lab_result(self, result: str) -> None:
@@ -67,6 +68,10 @@ class LabResultWatcherWorkflow:
     def discharge_patient(self) -> None:
         self._is_discharged = True
 
+    @workflow.query
+    def get_alerts(self) -> list:
+        return self._alerts
+
     @workflow.run
     async def run(self, baseline_data: dict) -> dict:
         """
@@ -103,6 +108,7 @@ class LabResultWatcherWorkflow:
                         anomaly_report,
                         start_to_close_timeout=timedelta(minutes=1)
                     )
+                    self._alerts.append(anomaly_report)
                     alerts_triggered += 1
 
         return {