Cache last timeout to avoid duplicate calls to conn.settimeout.
(self, timeout: Optional[float])
| 182 | self._cluster_time = None |
| 183 | |
| 184 | def set_conn_timeout(self, timeout: Optional[float]) -> None: |
| 185 | """Cache last timeout to avoid duplicate calls to conn.settimeout.""" |
| 186 | if timeout == self.last_timeout: |
| 187 | return |
| 188 | self.last_timeout = timeout |
| 189 | self.conn.get_conn.settimeout(timeout) |
| 190 | |
| 191 | def apply_timeout( |
| 192 | self, client: AsyncMongoClient[Any], cmd: Optional[MutableMapping[str, Any]] |
no test coverage detected