StreamΒΆ

async with app.resource(Incident) as r:
    selection = select(
        Incident.number.starts_with("INC0039")
        | Incident.opened_at.after("2019-05-05 01:35:50")
    ).order_desc(Incident.number)

    async for item in r.stream(selection, limit=0, chunk_size=250):
        print(item)