RDBC-999 Fix failing tests

Author: poissoncorp

.github/workflows/RavenClient.yml

@@ -25,7 +25,7 @@ jobs:
         RAVENDB_PYTHON_TEST_SERVER_CERTIFICATE_PATH: certs/server.pfx
         RAVENDB_PYTHON_TEST_CLIENT_CERTIFICATE_PATH: certs/python.pem
         RAVENDB_PYTHON_TEST_CA_PATH: /usr/local/share/ca-certificates/ca.crt
-        RAVENDB_PYTHON_TEST_HTTPS_SERVER_URL: https://localhost:7326
+        RAVENDB_PYTHON_TEST_HTTPS_SERVER_URL: https://localhost:8081
 
       strategy:
         matrix:
@@ -85,11 +85,9 @@ jobs:
         run: mkdir RavenDB/Server/certs && cp certs/server.pfx RavenDB/Server/certs/
 
       - name: Install black linter
-        if: ${{ matrix.python-version != '3.7' }}
         run: pip install black
 
       - name: Check code format
-        if: ${{ matrix.python-version != '3.7' }}
         run: black --check .
 
       - name: Run tests

ravendb/documents/conventions.py

@@ -87,6 +87,7 @@ def __init__(self):
         self.wait_for_indexes_after_save_changes_timeout = timedelta(seconds=15)
         self.wait_for_replication_after_save_changes_timeout = timedelta(seconds=15)
         self.wait_for_non_stale_results_timeout = timedelta(seconds=15)
+        self.max_empty_lines_in_jsonl_stream = 100
 
         # Balancing
         self._load_balancer_context_seed: Optional[int] = None

ravendb/documents/session/operations/stream.py

@@ -73,7 +73,9 @@ def set_result(self, response: StreamResultResponse) -> Iterator[Dict]:
         if response is None or response.stream_iterator is None:
             raise IndexDoesNotExistException("The index does not exists, failed to stream results")
 
-        parser = JSONLRavenStreamParser(response.stream_iterator)
+        parser = JSONLRavenStreamParser(
+            response.stream_iterator, self._session.conventions.max_empty_lines_in_jsonl_stream
+        )
 
         if self._is_query_stream:
             self._handle_stream_query_stats(parser, self._statistics)

ravendb/tools/parsers.py

@@ -1,4 +1,5 @@
 import json
+from json import JSONDecodeError
 from typing import Any, Iterator, Optional, Dict
 from decimal import InvalidOperation
 
@@ -249,16 +250,34 @@ def unescape(s):
 
 
 class JSONLRavenStreamParser:
-    def __init__(self, stream: Iterator):
+    def __init__(self, stream: Iterator, max_empty_lines: int = 100):
         self._stream = stream
         self._unused_buffer: Optional[Dict] = None
+        self._max_empty_lines = max_empty_lines
 
     def _get_next_json_dict(self) -> Dict:
-        return (
-            self._unused_buffer
-            if self._unused_buffer is not None
-            else json.loads(self._stream.__next__().decode("utf-8"))
-        )
+        if self._unused_buffer is not None:
+            return self._unused_buffer
+
+        empty_line_count = 0
+        while True:
+            json_data = self._stream.__next__().decode("utf-8").strip()
+
+            # Skip empty lines (standard in JSONL format)
+            if not json_data:
+                empty_line_count += 1
+                if empty_line_count >= self._max_empty_lines:
+                    raise RuntimeError(
+                        f"Received {self._max_empty_lines} consecutive empty lines in JSONL stream. "
+                        f"You can configure the maximum number of empty lines to ignore "
+                        f"using DocumentConventions.max_empty_lines_in_jsonl_stream."
+                    )
+                continue
+
+            try:
+                return json.loads(json_data)
+            except JSONDecodeError as e:
+                raise RuntimeError(f"Failed to parse JSON from stream: {json_data}") from e
 
     def purge_cache(self) -> None:
         self._unused_buffer = None