Sometimes these tests fail because there is garbage before.
elif method == "rows":
list(copy.rows())
+ gc_collect()
for retry in retries:
with retry:
n = []
for got, want in zip(recs, faker.records):
faker.assert_record(got, want)
+ gc_collect()
for retry in retries:
with retry:
n = []
async for x in copy.rows():
pass
+ gc_collect()
async for retry in retries:
with retry:
n = []
for got, want in zip(recs, faker.records):
faker.assert_record(got, want)
+ gc_collect()
async for retry in retries:
with retry:
n = []
row_factory = getattr(rows, row_factory)
n = []
+ gc_collect()
for i in range(3):
with psycopg.connect(dsn) as conn:
with conn.cursor(binary=fmt_out, row_factory=row_factory) as cur:
row_factory = getattr(rows, row_factory)
n = []
+ gc_collect()
for i in range(3):
async with await psycopg.AsyncConnection.connect(dsn) as conn:
async with conn.cursor(