Connection pool for pelt (epic E5).
MirrorsSqlitePool's acquire / release / close/
size shape so the Databasefacade treats both backends uniformly.
Pool construction acquires a process-wideTypeCatalogCache
keyed by host/port/database so checkouts reuse warmedpg_catalogmetadata
(#953). Closing the pool releases that shared reference.
data.drivers._pelt.pool
| Name | Type | Default | Description |
|---|---|---|---|
type
|
|
— | |
qualified_name
|
|
— | |
element_type
|
|
— | |
description
|
|
— | |
source_file
|
|
— | |
line_number
|
|
— | |
is_autodoc
|
|
— | |
autodoc_element
|
|
— | |
_autodoc_template
|
|
— | |
_autodoc_url_path
|
|
— | |
_autodoc_page_type
|
|
— | |
title
|
|
— | |
doc_content_hash
|
|
— |
Symbols on this page
A bounded pool ofConnectioninstances.
Create a bounded pool of authenticated PostgreSQL connections.
Acquires the process-wide type-catalog cache for the pool's connection target at construction time so worker startup…
Open a standalone connection (LISTEN/NOTIFY, scripts).
Pool
class
A bounded pool ofConnectioninstances.
create_pool
function
async
async def create_pool(config: PoolConfig) -> PoolCreate a bounded pool of authenticated PostgreSQL connections.
Acquires the process-wide type-catalog cache for the pool's connection target at construction time so worker startup can warm once and every checkout reuses the immutable snapshot.
Parameters
| Name | Type | Default | Description |
|---|---|---|---|
config
|
PoolConfig
|
— |
connect
function
async
async def connect(dsn: str, *, statement_cache_size: int = 100) -> ConnectionOpen a standalone connection (LISTEN/NOTIFY, scripts).
Parameters
| Name | Type | Default | Description |
|---|---|---|---|
dsn
|
str
|
— | |
statement_cache_size
|
int
|
100
|
View source · /home/runner/work/chirp/chirp/site/../src/chirp/data/drivers/_pelt/pool.py:1