refactor(ometa): drop noisy comment, expose timeout in SSE stream()

- Remove the fix-rationale comment from the request_kwargs block; that
  context lives in the PR description and would rot in-tree.
- Add an optional timeout parameter to SSEClient.stream(), forwarded to
  requests. Defaults to None (no timeout, prior behavior).

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

Author: pmbrull

ingestion/src/metadata/ingestion/ometa/sse_client.py

@@ -36,7 +36,13 @@ def __init__(self, config: ClientConfig, max_retries=5, retry_delay=2):
         self.stream_completed: bool = False
         self.logger: Logger = ometa_logger()
 
-    def stream(self, method: str, path: str, data: None | dict[str, Any] = None) -> Generator[Any, Any, None]:
+    def stream(
+        self,
+        method: str,
+        path: str,
+        data: None | dict[str, Any] = None,
+        timeout: None | float | tuple[float, float] = None,
+    ) -> Generator[Any, Any, None]:
         """Connect to the SSE stream and yield events.
 
         Args:
@@ -87,18 +93,14 @@ def stream(self, method: str, path: str, data: None | dict[str, Any] = None) ->
                 if self.last_event_id:
                     headers["Last-Event-ID"] = self.last_event_id
 
-                # SSE transport uses `requests` rather than `httpx`: the SDK's REST client
-                # already uses requests, and some enterprise security middleboxes reject
-                # httpx's HTTP/1.1 wire pattern (lowercase header names, header/body in
-                # separate TCP segments) while passing requests/wget through unchanged.
                 request_kwargs = {
                     "method": method,
                     "url": str(url),
                     "headers": headers,
                     "json": opts.get("json"),
                     "params": opts.get("params"),
                     "stream": True,
-                    "timeout": None,
+                    "timeout": timeout,
                     "verify": (
                         self.config.verify if self.config.verify is not None else True
                     ),