diff --git a/atvm/watcher-service/atvm_run_watcher.py b/atvm/watcher-service/atvm_run_watcher.py
index aff180e..7aa8f9f 100644
--- a/atvm/watcher-service/atvm_run_watcher.py
+++ b/atvm/watcher-service/atvm_run_watcher.py
@@ -276,7 +276,13 @@ def parse_duration_seconds(raw: str) -> Optional[float]:
 
 def extract_completed_subrun_summaries(log_text: str, inventory: Dict[str, str]) -> List[Dict[str, object]]:
     summaries: List[Dict[str, object]] = []
-    cloud_blocks = list(re.finditer(r"Cloud Run Finished(.*?)(?:🏁 Recorded Run:\s*(https://\S+))", log_text, re.S))
+    cloud_blocks = list(
+        re.finditer(
+            r"Cloud Run Finished(.*?)(?:🏁 Recorded Run:\s*(https://\S+)|\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2},\d{3} - INFO - Detected 'Recorded Run' after 'Cloud Run Finished' - results uploaded successfully\.)",
+            log_text,
+            re.S,
+        )
+    )
     for block in cloud_blocks:
         block_text = block.group(1)
         currents_url = block.group(2)