Ограничие asyncio task по памяти?

Алексей Черемисин, Использовал ваш пример, работает, но вопрос появился новый, когда except срабатывает, получается мы отбрасывает эту задачу, как ее повторно отработать?! При таком подходе, когда данные в бд ложишь, происходит лимит соединений, как можно этот момент учитывать? использовать pgbouncer?

Ограничие asyncio task по памяти?

Набросал, все равно по максимуму идет нагрузка. В этой теме плохо разбираюсь, поэтому все спрашиваю

def read_json(path):
    with jsonlines.open(path) as reader:
        for inx, obj in enumerate(reader, start=1):
            yield obj

async def main(path, engine):
    N = 100
    tasks = asyncio.Queue()

    for item in read_json(path=path):
        tasks.put_nowait(load_today_db(engine=engine, obj=item))

    async def worker():
        while not tasks.empty():
            await tasks.get_nowait()

    await asyncio.gather(*[worker() for _ in range(N)])

Ограничие asyncio task по памяти?

Подробнее можно?! Не совсем понял как можно применить