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