Disable replication on all secondaries.
(self, client)
| 1129 | return client |
| 1130 | |
| 1131 | def disable_replication(self, client): |
| 1132 | """Disable replication on all secondaries.""" |
| 1133 | for h, p in client.secondaries: |
| 1134 | secondary = self.single_client(h, p) |
| 1135 | secondary.admin.command("configureFailPoint", "stopReplProducer", mode="alwaysOn") |
| 1136 | |
| 1137 | def enable_replication(self, client): |
| 1138 | """Enable replication on all secondaries.""" |