Skip to content
This repository was archived by the owner on Mar 31, 2026. It is now read-only.

Commit 12ca001

Browse files
1 parent b96dae3 commit 12ca001

File tree

292 files changed

+48
-133226
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

292 files changed

+48
-133226
lines changed

google/cloud/spanner_v1/types/__init__.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,9 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16+
from .change_stream import (
17+
ChangeStreamRecord,
18+
)
1619
from .commit_response import (
1720
CommitResponse,
1821
)
@@ -73,6 +76,7 @@
7376
)
7477

7578
__all__ = (
79+
"ChangeStreamRecord",
7680
"CommitResponse",
7781
"KeyRange",
7882
"KeySet",

owl-bot-staging/spanner/v1/google/cloud/spanner_v1/types/change_stream.py renamed to google/cloud/spanner_v1/types/change_stream.py

Lines changed: 44 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@
2525

2626

2727
__protobuf__ = proto.module(
28-
package='google.spanner.v1',
28+
package="google.spanner.v1",
2929
manifest={
30-
'ChangeStreamRecord',
30+
"ChangeStreamRecord",
3131
},
3232
)
3333

@@ -161,6 +161,7 @@ class DataChangeRecord(proto.Message):
161161
issued by time-to-live (TTL), column backfill,
162162
etc.
163163
"""
164+
164165
class ModType(proto.Enum):
165166
r"""Mod type describes the type of change Spanner applied to the data.
166167
For example, if the client submits an INSERT_OR_UPDATE request,
@@ -290,20 +291,26 @@ class Mod(proto.Message):
290291
[DELETE][google.spanner.v1.ChangeStreamRecord.DataChangeRecord.ModType.DELETE].
291292
"""
292293

293-
keys: MutableSequence['ChangeStreamRecord.DataChangeRecord.ModValue'] = proto.RepeatedField(
294+
keys: MutableSequence[
295+
"ChangeStreamRecord.DataChangeRecord.ModValue"
296+
] = proto.RepeatedField(
294297
proto.MESSAGE,
295298
number=1,
296-
message='ChangeStreamRecord.DataChangeRecord.ModValue',
299+
message="ChangeStreamRecord.DataChangeRecord.ModValue",
297300
)
298-
old_values: MutableSequence['ChangeStreamRecord.DataChangeRecord.ModValue'] = proto.RepeatedField(
301+
old_values: MutableSequence[
302+
"ChangeStreamRecord.DataChangeRecord.ModValue"
303+
] = proto.RepeatedField(
299304
proto.MESSAGE,
300305
number=2,
301-
message='ChangeStreamRecord.DataChangeRecord.ModValue',
306+
message="ChangeStreamRecord.DataChangeRecord.ModValue",
302307
)
303-
new_values: MutableSequence['ChangeStreamRecord.DataChangeRecord.ModValue'] = proto.RepeatedField(
308+
new_values: MutableSequence[
309+
"ChangeStreamRecord.DataChangeRecord.ModValue"
310+
] = proto.RepeatedField(
304311
proto.MESSAGE,
305312
number=3,
306-
message='ChangeStreamRecord.DataChangeRecord.ModValue',
313+
message="ChangeStreamRecord.DataChangeRecord.ModValue",
307314
)
308315

309316
commit_timestamp: timestamp_pb2.Timestamp = proto.Field(
@@ -327,25 +334,31 @@ class Mod(proto.Message):
327334
proto.STRING,
328335
number=5,
329336
)
330-
column_metadata: MutableSequence['ChangeStreamRecord.DataChangeRecord.ColumnMetadata'] = proto.RepeatedField(
337+
column_metadata: MutableSequence[
338+
"ChangeStreamRecord.DataChangeRecord.ColumnMetadata"
339+
] = proto.RepeatedField(
331340
proto.MESSAGE,
332341
number=6,
333-
message='ChangeStreamRecord.DataChangeRecord.ColumnMetadata',
342+
message="ChangeStreamRecord.DataChangeRecord.ColumnMetadata",
334343
)
335-
mods: MutableSequence['ChangeStreamRecord.DataChangeRecord.Mod'] = proto.RepeatedField(
344+
mods: MutableSequence[
345+
"ChangeStreamRecord.DataChangeRecord.Mod"
346+
] = proto.RepeatedField(
336347
proto.MESSAGE,
337348
number=7,
338-
message='ChangeStreamRecord.DataChangeRecord.Mod',
349+
message="ChangeStreamRecord.DataChangeRecord.Mod",
339350
)
340-
mod_type: 'ChangeStreamRecord.DataChangeRecord.ModType' = proto.Field(
351+
mod_type: "ChangeStreamRecord.DataChangeRecord.ModType" = proto.Field(
341352
proto.ENUM,
342353
number=8,
343-
enum='ChangeStreamRecord.DataChangeRecord.ModType',
354+
enum="ChangeStreamRecord.DataChangeRecord.ModType",
344355
)
345-
value_capture_type: 'ChangeStreamRecord.DataChangeRecord.ValueCaptureType' = proto.Field(
346-
proto.ENUM,
347-
number=9,
348-
enum='ChangeStreamRecord.DataChangeRecord.ValueCaptureType',
356+
value_capture_type: "ChangeStreamRecord.DataChangeRecord.ValueCaptureType" = (
357+
proto.Field(
358+
proto.ENUM,
359+
number=9,
360+
enum="ChangeStreamRecord.DataChangeRecord.ValueCaptureType",
361+
)
349362
)
350363
number_of_records_in_transaction: int = proto.Field(
351364
proto.INT32,
@@ -637,45 +650,49 @@ class MoveOutEvent(proto.Message):
637650
proto.STRING,
638651
number=3,
639652
)
640-
move_in_events: MutableSequence['ChangeStreamRecord.PartitionEventRecord.MoveInEvent'] = proto.RepeatedField(
653+
move_in_events: MutableSequence[
654+
"ChangeStreamRecord.PartitionEventRecord.MoveInEvent"
655+
] = proto.RepeatedField(
641656
proto.MESSAGE,
642657
number=4,
643-
message='ChangeStreamRecord.PartitionEventRecord.MoveInEvent',
658+
message="ChangeStreamRecord.PartitionEventRecord.MoveInEvent",
644659
)
645-
move_out_events: MutableSequence['ChangeStreamRecord.PartitionEventRecord.MoveOutEvent'] = proto.RepeatedField(
660+
move_out_events: MutableSequence[
661+
"ChangeStreamRecord.PartitionEventRecord.MoveOutEvent"
662+
] = proto.RepeatedField(
646663
proto.MESSAGE,
647664
number=5,
648-
message='ChangeStreamRecord.PartitionEventRecord.MoveOutEvent',
665+
message="ChangeStreamRecord.PartitionEventRecord.MoveOutEvent",
649666
)
650667

651668
data_change_record: DataChangeRecord = proto.Field(
652669
proto.MESSAGE,
653670
number=1,
654-
oneof='record',
671+
oneof="record",
655672
message=DataChangeRecord,
656673
)
657674
heartbeat_record: HeartbeatRecord = proto.Field(
658675
proto.MESSAGE,
659676
number=2,
660-
oneof='record',
677+
oneof="record",
661678
message=HeartbeatRecord,
662679
)
663680
partition_start_record: PartitionStartRecord = proto.Field(
664681
proto.MESSAGE,
665682
number=3,
666-
oneof='record',
683+
oneof="record",
667684
message=PartitionStartRecord,
668685
)
669686
partition_end_record: PartitionEndRecord = proto.Field(
670687
proto.MESSAGE,
671688
number=4,
672-
oneof='record',
689+
oneof="record",
673690
message=PartitionEndRecord,
674691
)
675692
partition_event_record: PartitionEventRecord = proto.Field(
676693
proto.MESSAGE,
677694
number=5,
678-
oneof='record',
695+
oneof="record",
679696
message=PartitionEventRecord,
680697
)
681698

owl-bot-staging/spanner/v1/.coveragerc

Lines changed: 0 additions & 13 deletions
This file was deleted.

owl-bot-staging/spanner/v1/.flake8

Lines changed: 0 additions & 34 deletions
This file was deleted.

0 commit comments

Comments
 (0)