(self)
| 401 | @client_context.require_replica_set |
| 402 | @client_context.require_failCommand_fail_point |
| 403 | def setUp(self) -> None: |
| 404 | super().setUp() |
| 405 | self.fail_insert = { |
| 406 | "configureFailPoint": "failCommand", |
| 407 | "mode": {"times": 2}, |
| 408 | "data": { |
| 409 | "failCommands": ["insert"], |
| 410 | "writeConcernError": {"code": 91, "errmsg": "Replication is being shut down"}, |
| 411 | }, |
| 412 | } |
| 413 | |
| 414 | @client_context.require_version_min(4, 0) |
| 415 | @client_knobs(heartbeat_frequency=0.05, min_heartbeat_interval=0.05) |