Commit ddf9508

authored

PYTHON-5510 Fix server selection log message for commitTransaction (#2503)

1 parent e08284b commit ddf9508Copy full SHA for ddf9508

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -167,7 +167,6 @@`
`167`	`167`	`WTimeoutError,`
`168`	`168`	`)`
`169`	`169`	`from pymongo.helpers_shared import _RETRYABLE_ERROR_CODES`
`170`		`-from pymongo.operations import _Op`
`171`	`170`	`from pymongo.read_concern import ReadConcern`
`172`	`171`	`from pymongo.read_preferences import ReadPreference, _ServerMode`
`173`	`172`	`from pymongo.server_type import SERVER_TYPE`
`@@ -868,7 +867,7 @@ async def func(`
`868`	`867`	`return await self._finish_transaction(conn, command_name)`
`869`	`868`
`870`	`869`	`return await self._client._retry_internal(`
`871`		`- func, self, None, retryable=True, operation=_Op.ABORT`
	`870`	`+ func, self, None, retryable=True, operation=command_name`
`872`	`871`	`)`
`873`	`872`
`874`	`873`	`async def _finish_transaction(self, conn: AsyncConnection, command_name: str) -> dict[str, Any]:`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,6 @@`
`165`	`165`	`WTimeoutError,`
`166`	`166`	`)`
`167`	`167`	`from pymongo.helpers_shared import _RETRYABLE_ERROR_CODES`
`168`		`-from pymongo.operations import _Op`
`169`	`168`	`from pymongo.read_concern import ReadConcern`
`170`	`169`	`from pymongo.read_preferences import ReadPreference, _ServerMode`
`171`	`170`	`from pymongo.server_type import SERVER_TYPE`
`@@ -864,7 +863,9 @@ def func(`
`864`	`863`	`) -> dict[str, Any]:`
`865`	`864`	`return self._finish_transaction(conn, command_name)`
`866`	`865`
`867`		`- return self._client._retry_internal(func, self, None, retryable=True, operation=_Op.ABORT)`
	`866`	`+ return self._client._retry_internal(`
	`867`	`+ func, self, None, retryable=True, operation=command_name`
	`868`	`+ )`
`868`	`869`
`869`	`870`	`def _finish_transaction(self, conn: Connection, command_name: str) -> dict[str, Any]:`
`870`	`871`	`self._transaction.attempt += 1`

Comments

(0)