Repository navigation
test(spanner): add tests for consuming PartialResultSet streams - #18604
Conversation
![gemini-code-assist[bot]](https://avatars.githubusercontent.com/in/956858?s=60&v=4){kind=small}
There was a problem hiding this comment.
Code Review
This pull request adds comprehensive unit and acceptance tests for streaming chunked values (including empty strings, empty lists, bytes, resumption across retries, numeric, and JSON types) in both synchronous and asynchronous test suites. It also updates the _normalize_results helper to support NUMERIC and JSON types and handle None values. The feedback identifies two instances in the asynchronous tests where the built-in anext() function is used, which will raise a NameError on Python versions prior to 3.10. It is recommended to use the __anext__() dunder method instead to ensure backward compatibility.
Adds a few missing test cases for consuming PartialResultSet streams to the Spanner Python client.
a55353c to
000c171
Compare
|
/gemini review |
There was a problem hiding this comment.
Code Review
This pull request adds comprehensive unit tests and acceptance tests for chunked value merging and streaming reads in the Google Cloud Spanner Python client, covering both synchronous and asynchronous implementations. Specifically, it introduces test cases for merging chunks of various data types—including FLOAT32, DATE, TIMESTAMP, INTERVAL, UUID, NUMERIC, and JSON—as well as their array counterparts. Additionally, the _normalize_results helper function in the test suites has been updated to correctly handle and normalize these new types and null values. I have no feedback to provide as there are no review comments.
Combines all non-draft, non-'do not merge' Spanner micro-optimization PRs: - #18329: perf(spanner): optimize built-in metrics hot path and harden concurrency - #18359: perf(spanner): optimize query parameter encoding with direct type dispatch - #18379: perf(spanner): build ExecuteSqlRequest on the raw protobuf message - #18408: perf(spanner): optimize request ID header generation and retry closures - #18420: perf(spanner): prune lock and begin event allocations on single-use snapshots - #18422: perf(spanner): avoid allocating empty RequestOptions on read and query paths - #18602: perf(spanner): optimize single-chunk results and single-row lookups - #18604: test(spanner): add tests for consuming PartialResultSet streams
2 participants
Adds a few missing test cases for consuming PartialResultSet streams to the Spanner Python client.