@@ -16,9 +16,11 @@
|
16 | 16 | # This file is automatically generated by CrossSync. Do not edit manually. |
17 | 17 | |
18 | 18 | """Model a set of read-only queries to a database as a snapshot.""" |
| 19 | + |
19 | 20 | import functools |
20 | 21 | import threading |
21 | 22 | from typing import List, Optional, Union |
| 23 | + |
22 | 24 | from google.api_core import gapic_v1 |
23 | 25 | from google.api_core.exceptions import ( |
24 | 26 | Aborted, |
@@ -27,24 +29,25 @@
|
27 | 29 | ServiceUnavailable, |
28 | 30 | ) |
29 | 31 | from google.protobuf.struct_pb2 import Struct |
| 32 | + |
30 | 33 | from google.cloud.aio._cross_sync import CrossSync |
31 | | -from google.cloud.spanner_v1._helpers import _retry |
32 | | -from google.cloud.spanner_v1.streamed import StreamedResultSet |
33 | 34 | from google.cloud.spanner_v1._helpers import ( |
34 | 35 | AtomicCounter, |
35 | 36 | _augment_error_with_request_id, |
36 | 37 | _check_rst_stream_error, |
37 | 38 | _make_value_pb, |
| 39 | +_merge_client_context, |
38 | 40 | _merge_query_options, |
| 41 | +_merge_request_options, |
39 | 42 | _metadata_with_leader_aware_routing, |
40 | 43 | _metadata_with_prefix, |
| 44 | +_retry, |
41 | 45 | _SessionWrapper, |
42 | 46 | _validate_client_context, |
43 | | -_merge_client_context, |
44 | | -_merge_request_options, |
45 | 47 | ) |
46 | 48 | from google.cloud.spanner_v1._opentelemetry_tracing import add_span_event, trace_call |
47 | 49 | from google.cloud.spanner_v1.metrics.metrics_capture import MetricsCapture |
| 50 | +from google.cloud.spanner_v1.streamed import StreamedResultSet |
48 | 51 | from google.cloud.spanner_v1.types import MultiplexedSessionPrecommitToken |
49 | 52 | from google.cloud.spanner_v1.types.mutation import Mutation |
50 | 53 | from google.cloud.spanner_v1.types.result_set import PartialResultSet, ResultSet |
|