(
_session: Optional[AsyncClientSession],
server: Server,
conn: AsyncConnection,
read_preference: _ServerMode,
)
| 1942 | ) |
| 1943 | |
| 1944 | async def _cmd( |
| 1945 | _session: Optional[AsyncClientSession], |
| 1946 | server: Server, |
| 1947 | conn: AsyncConnection, |
| 1948 | read_preference: _ServerMode, |
| 1949 | ) -> Response: |
| 1950 | operation.reset() # Reset op in case of retry. |
| 1951 | return await server.run_operation( |
| 1952 | conn, |
| 1953 | operation, |
| 1954 | read_preference, |
| 1955 | self._event_listeners, |
| 1956 | unpack_res, |
| 1957 | self, |
| 1958 | ) |
| 1959 | |
| 1960 | return await self._retryable_read( |
| 1961 | _cmd, |
nothing calls this directly
no test coverage detected