(cls, **kwargs)
| 531 | |
| 532 | @classmethod |
| 533 | def connect_primary(cls, **kwargs): |
| 534 | conn_spec = cls.get_cluster_connection_spec(cls.master_cluster, kwargs) |
| 535 | return pg_connection.connect(**conn_spec, loop=cls.loop) |
| 536 | |
| 537 | @classmethod |
| 538 | def connect_standby(cls, **kwargs): |
nothing calls this directly
no test coverage detected