(ClusterCls, cluster_kwargs, initdb_options=None)
| 219 | |
| 220 | |
| 221 | def _init_cluster(ClusterCls, cluster_kwargs, initdb_options=None): |
| 222 | cluster = ClusterCls(**cluster_kwargs) |
| 223 | cluster.init(**(initdb_options or {})) |
| 224 | cluster.trust_local_connections() |
| 225 | atexit.register(_shutdown_cluster, cluster) |
| 226 | return cluster |
| 227 | |
| 228 | |
| 229 | def _get_initdb_options(initdb_options=None): |
no test coverage detected
searching dependent graphs…