Method close

pymongo/asynchronous/mongo_client.py:1725–1759

Cleanup client resources and disconnect from MongoDB. End all server sessions created by this client by sending one or more endSessions commands. Close all sockets in the connection pools and stop the monitor threads. .. versionchanged:: 4.0 Once closed,

(self)

            pass

    async def close(self) -> None:
        """Cleanup client resources and disconnect from MongoDB.

        End all server sessions created by this client by sending one or more
        endSessions commands.

        Close all sockets in the connection pools and stop the monitor threads.

        .. versionchanged:: 4.0
           Once closed, the client cannot be used again and any attempt will
           raise :exc:`~pymongo.errors.InvalidOperation`.

        .. versionchanged:: 3.6
           End all server sessions created by this client.
        """
        if self._topology is None:
            return
        session_ids = self._topology.pop_all_sessions()
        if session_ids:
            await self._end_sessions(session_ids)
        # Stop the periodic task thread and then send pending killCursor
        # requests before closing the topology.
        self._kill_cursors_executor.close()
        await self._process_kill_cursors()
        await self._topology.close()
        if self._encrypter:
            # TODO: PYTHON-1921 Encrypted MongoClients cannot be re-opened.
            await self._encrypter.close()
        self._closed = True
        if not _IS_SYNC:
            await asyncio.gather(
                self._topology.cleanup_monitors(),  # type: ignore[func-returns-value]
                self._kill_cursors_executor.join(),  # type: ignore[func-returns-value]
                return_exceptions=True,
            )

    if not _IS_SYNC:
        # Add support for contextlib.aclosing.