def worker(i):
try:
logging.info("worker %s started", i)
- nonlocal got_conns
-
with p.connection() as conn:
logging.info("worker %s got conn", i)
cur = conn.execute("select 1")
async def worker(i):
try:
logging.info("worker %s started", i)
- nonlocal got_conns
-
async with p.connection() as conn:
logging.info("worker %s got conn", i)
cur = await conn.execute("select 1")
def worker(i):
try:
logging.info("worker %s started", i)
- nonlocal got_conns
-
with p.connection() as conn:
logging.info("worker %s got conn", i)
cur = conn.execute("select 1")
async def worker(i):
try:
logging.info("worker %s started", i)
- nonlocal got_conns
-
async with p.connection() as conn:
logging.info("worker %s got conn", i)
cur = await conn.execute("select 1")
def worker(i):
try:
logging.info("worker %s started", i)
- nonlocal got_conns
-
with p.connection() as conn:
logging.info("worker %s got conn", i)
cur = conn.execute("select 1")
async def worker(i):
try:
logging.info("worker %s started", i)
- nonlocal got_conns
-
async with p.connection() as conn:
logging.info("worker %s got conn", i)
cur = await conn.execute("select 1")
stop = False
def committer():
- nonlocal stop
while not stop:
conn.commit()
stop = False
async def committer():
- nonlocal stop
while not stop:
await aconn.commit()
await asyncio.sleep(0) # Allow the other worker to work
checked: list[pq.DiagnosticField] = []
def check_val(self, v):
- nonlocal to_check
assert to_check == v
checked.append(v)
return None