(self, wait=60, *, server_settings={}, **opts)
| 683 | return output.decode() |
| 684 | |
| 685 | def start(self, wait=60, *, server_settings={}, **opts): |
| 686 | if self._pg_version >= (12, 0): |
| 687 | server_settings = server_settings.copy() |
| 688 | server_settings['primary_conninfo'] = ( |
| 689 | '"host={host} port={port} user={user}"'.format( |
| 690 | host=self._master['host'], |
| 691 | port=self._master['port'], |
| 692 | user=self._repl_user, |
| 693 | ) |
| 694 | ) |
| 695 | |
| 696 | super().start(wait=wait, server_settings=server_settings, **opts) |
| 697 | |
| 698 | |
| 699 | class RunningCluster(Cluster): |