diff --git a/pymongo/asynchronous/collection.py b/pymongo/asynchronous/collection.py index 1595828260..924635d7dc 100644 --- a/pymongo/asynchronous/collection.py +++ b/pymongo/asynchronous/collection.py @@ -390,15 +390,6 @@ def with_options( read_concern or self.read_concern, ) - def _write_concern_for_cmd( - self, cmd: Mapping[str, Any], session: Optional[AsyncClientSession] - ) -> WriteConcern: - raw_wc = cmd.get("writeConcern") - if raw_wc is not None: - return WriteConcern(**raw_wc) - else: - return self._write_concern_for(session) - # See PYTHON-3084. __iter__ = None diff --git a/pymongo/common.py b/pymongo/common.py index 602db913ae..dc18b937e5 100644 --- a/pymongo/common.py +++ b/pymongo/common.py @@ -978,6 +978,15 @@ def _write_concern_for(self, session: Optional[_AgnosticClientSession]) -> Write return DEFAULT_WRITE_CONCERN return self.write_concern + def _write_concern_for_cmd( + self, cmd: Mapping[str, Any], session: Optional[_AgnosticClientSession] + ) -> WriteConcern: + raw_wc = cmd.get("writeConcern") + if raw_wc is not None: + return WriteConcern(**raw_wc) + else: + return self._write_concern_for(session) + @property def read_preference(self) -> _ServerMode: """Read only access to the read preference of this instance. diff --git a/pymongo/synchronous/collection.py b/pymongo/synchronous/collection.py index cf8cdb7842..931001e179 100644 --- a/pymongo/synchronous/collection.py +++ b/pymongo/synchronous/collection.py @@ -392,15 +392,6 @@ def with_options( read_concern or self.read_concern, ) - def _write_concern_for_cmd( - self, cmd: Mapping[str, Any], session: Optional[ClientSession] - ) -> WriteConcern: - raw_wc = cmd.get("writeConcern") - if raw_wc is not None: - return WriteConcern(**raw_wc) - else: - return self._write_concern_for(session) - # See PYTHON-3084. __iter__ = None