fix(sessions): resolve async deadlock in multiplexed session manager … · googleapis/google-cloud-python@c8f936b
@@ -162,7 +162,7 @@ def rollback(self) -> None:
162162163163def wrapped_method(*args, **kwargs):
164164attempt.increment()
165-(call_metadata, error_augmenter) = database.with_error_augmentation(
165+call_metadata, error_augmenter = database.with_error_augmentation(
166166nth_request, attempt.value, metadata, span
167167 )
168168rollback_method = functools.partial(
@@ -269,7 +269,7 @@ def wrapped_method(*args, **kwargs):
269269is_multiplexed = getattr(self._session, "is_multiplexed", False)
270270if is_multiplexed and self._precommit_token is not None:
271271commit_request_args["precommit_token"] = self._precommit_token
272-(call_metadata, error_augmenter) = database.with_error_augmentation(
272+call_metadata, error_augmenter = database.with_error_augmentation(
273273nth_request, attempt.value, metadata, span
274274 )
275275commit_method = functools.partial(
@@ -300,7 +300,7 @@ def before_next_retry(nth_retry, delay_in_seconds):
300300if commit_response_pb._pb.HasField("precommit_token"):
301301add_span_event(span, commit_retry_event_name)
302302nth_request = database._next_nth_request
303-(call_metadata, error_augmenter) = database.with_error_augmentation(
303+call_metadata, error_augmenter = database.with_error_augmentation(
304304nth_request, 1, metadata, span
305305 )
306306with error_augmenter:
@@ -338,7 +338,7 @@ def _make_params_pb(params, param_types):
338338 If ``params`` is None but ``param_types`` is not None."""
339339if params:
340340return Struct(
341-fields={key: _make_value_pb(value) for (key, value) in params.items()}
341+fields={key: _make_value_pb(value) for key, value in params.items()}
342342 )
343343return {}
344344@@ -417,7 +417,7 @@ def execute_update(
417417metadata.append(
418418_metadata_with_leader_aware_routing(database._route_to_leader_enabled)
419419 )
420-(seqno, self._execute_sql_request_count) = (
420+seqno, self._execute_sql_request_count = (
421421self._execute_sql_request_count,
422422self._execute_sql_request_count + 1,
423423 )
@@ -454,7 +454,7 @@ def execute_update(
454454455455def wrapped_method(*args, **kwargs):
456456attempt.increment()
457-(call_metadata, error_augmenter) = database.with_error_augmentation(
457+call_metadata, error_augmenter = database.with_error_augmentation(
458458nth_request, attempt.value, metadata
459459 )
460460execute_sql_method = functools.partial(
@@ -544,7 +544,7 @@ def batch_update(
544544if isinstance(statement, str):
545545parsed.append(ExecuteBatchDmlRequest.Statement(sql=statement))
546546else:
547-(dml, params, param_types) = statement
547+dml, params, param_types = statement
548548params_pb = self._make_params_pb(params, param_types)
549549parsed.append(
550550ExecuteBatchDmlRequest.Statement(
@@ -556,7 +556,7 @@ def batch_update(
556556metadata.append(
557557_metadata_with_leader_aware_routing(database._route_to_leader_enabled)
558558 )
559-(seqno, self._execute_sql_request_count) = (
559+seqno, self._execute_sql_request_count = (
560560self._execute_sql_request_count,
561561self._execute_sql_request_count + 1,
562562 )
@@ -590,7 +590,7 @@ def batch_update(
590590591591def wrapped_method(*args, **kwargs):
592592attempt.increment()
593-(call_metadata, error_augmenter) = database.with_error_augmentation(
593+call_metadata, error_augmenter = database.with_error_augmentation(
594594nth_request, attempt.value, metadata
595595 )
596596execute_batch_dml_method = functools.partial(