fix(tracing): parse PascalCase /logs response from gateway

The gateway /logs endpoint returns entries with PascalCase keys
(CreatedAt, Message, Severity, Tags, Extras) and flattened
StatusCode / StatusMessage / StatusDetails fields, while the SDK
expected snake_case and a nested `status` dict. This mismatch caused
RemoteRolloutProcessor's status polling to never detect completion and
time out after 180s. Map the fields client-side and reconstruct the
nested status dict for both sync and async search_logs.

Made-with: Cursor

Author: xzrderek

eval_protocol/adapters/fireworks_tracing.py

@@ -306,17 +306,26 @@ def search_logs(self, tags: List[str], limit: int = 100, hours_back: int = 24) -
             return []
 
         entries: List[Dict[str, Any]] = data.get("entries", []) or []
-        # Normalize minimal shape
+        # Normalize minimal shape; reconstruct a nested `status` dict from the
+        # flattened StatusCode / StatusMessage / StatusDetails fields.
         results: List[Dict[str, Any]] = []
         for e in entries:
+            status_code = e.get("StatusCode")
+            status: Optional[Dict[str, Any]] = None
+            if status_code is not None:
+                status = {
+                    "code": status_code,
+                    "message": e.get("StatusMessage"),
+                    "details": e.get("StatusDetails") or [],
+                }
             results.append(
                 {
-                    "timestamp": e.get("timestamp"),
-                    "message": e.get("message"),
-                    "severity": e.get("severity", "INFO"),
-                    "tags": e.get("tags", []),
-                    "status": e.get("status"),
-                    "extras": e.get("extras"),
+                    "timestamp": e.get("CreatedAt"),
+                    "message": e.get("Message"),
+                    "severity": e.get("Severity", "INFO"),
+                    "tags": e.get("Tags") or [],
+                    "status": status,
+                    "extras": e.get("Extras"),
                 }
             )
         return results
@@ -353,16 +362,26 @@ async def async_search_logs(
             return []
 
         entries: List[Dict[str, Any]] = data.get("entries", []) or []
+        # Normalize minimal shape; reconstruct a nested `status` dict from the
+        # flattened StatusCode / StatusMessage / StatusDetails fields.
         results: List[Dict[str, Any]] = []
         for e in entries:
+            status_code = e.get("StatusCode")
+            status: Optional[Dict[str, Any]] = None
+            if status_code is not None:
+                status = {
+                    "code": status_code,
+                    "message": e.get("StatusMessage"),
+                    "details": e.get("StatusDetails") or [],
+                }
             results.append(
                 {
-                    "timestamp": e.get("timestamp"),
-                    "message": e.get("message"),
-                    "severity": e.get("severity", "INFO"),
-                    "tags": e.get("tags", []),
-                    "status": e.get("status"),
-                    "extras": e.get("extras"),
+                    "timestamp": e.get("CreatedAt"),
+                    "message": e.get("Message"),
+                    "severity": e.get("Severity", "INFO"),
+                    "tags": e.get("Tags") or [],
+                    "status": status,
+                    "extras": e.get("Extras"),
                 }
             )
         return results