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

Commit 760d6cd

Browse files
committed
Update propagation of changes
1 parent 8c7a8bb commit 760d6cd

File tree

3 files changed

+187
-49
lines changed

3 files changed

+187
-49
lines changed

google/cloud/spanner_v1/client.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
"""
2626
import grpc
2727
import os
28+
import sys
2829
import warnings
2930

3031
from google.api_core.gapic_v1 import client_info
@@ -203,10 +204,11 @@ def __init__(
203204
self._directed_read_options = directed_read_options
204205
self._observability_options = observability_options
205206
self._nth_client_id = Client.NTH_CLIENT.increment()
206-
self._nth_request = AtomicCounter()
207+
self._nth_request = AtomicCounter(0)
207208

208209
@property
209210
def _next_nth_request(self):
211+
print("next_nth_request called by", sys._getframe().f_back.f_code.co_name)
210212
return self._nth_request.increment()
211213

212214
@property

google/cloud/spanner_v1/session.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -259,12 +259,7 @@ def delete(self):
259259
},
260260
observability_options=observability_options,
261261
):
262-
api.delete_session(
263-
name=self.name,
264-
metadata=database.metadata_with_request_id(
265-
database._next_nth_request, 1, metadata
266-
),
267-
)
262+
api.delete_session(name=self.name, metadata=metadata)
268263

269264
def ping(self):
270265
"""Ping the session to keep it alive by executing "SELECT 1".

0 commit comments

Comments
 (0)