Visitar URL original
PYTHON-6021 Move _write_concern_for_cmd into BaseObject (#3036) · mongodb/mongo-python-driver@22a2ec8 · GitHub
Skip to content

Commit 22a2ec8

Browse files
authored
PYTHON-6021 Move _write_concern_for_cmd into BaseObject (#3036)
1 parent 2a4a004 commit 22a2ec8

3 files changed

Lines changed: 9 additions & 18 deletions

File tree

‎pymongo/asynchronous/collection.py‎

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -390,15 +390,6 @@ def with_options(
390390
read_concern or self.read_concern,
391391
)
392392

393-
def _write_concern_for_cmd(
394-
self, cmd: Mapping[str, Any], session: Optional[AsyncClientSession]
395-
) -> WriteConcern:
396-
raw_wc = cmd.get("writeConcern")
397-
if raw_wc is not None:
398-
return WriteConcern(**raw_wc)
399-
else:
400-
return self._write_concern_for(session)
401-
402393
# See PYTHON-3084.
403394
__iter__ = None
404395

‎pymongo/common.py‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -978,6 +978,15 @@ def _write_concern_for(self, session: Optional[_AgnosticClientSession]) -> Write
978978
return DEFAULT_WRITE_CONCERN
979979
return self.write_concern
980980

981+
def _write_concern_for_cmd(
982+
self, cmd: Mapping[str, Any], session: Optional[_AgnosticClientSession]
983+
) -> WriteConcern:
984+
raw_wc = cmd.get("writeConcern")
985+
if raw_wc is not None:
986+
return WriteConcern(**raw_wc)
987+
else:
988+
return self._write_concern_for(session)
989+
981990
@property
982991
def read_preference(self) -> _ServerMode:
983992
"""Read only access to the read preference of this instance.

‎pymongo/synchronous/collection.py‎

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -392,15 +392,6 @@ def with_options(
392392
read_concern or self.read_concern,
393393
)
394394

395-
def _write_concern_for_cmd(
396-
self, cmd: Mapping[str, Any], session: Optional[ClientSession]
397-
) -> WriteConcern:
398-
raw_wc = cmd.get("writeConcern")
399-
if raw_wc is not None:
400-
return WriteConcern(**raw_wc)
401-
else:
402-
return self._write_concern_for(session)
403-
404395
# See PYTHON-3084.
405396
__iter__ = None
406397

0 commit comments

Comments
 (0)