.
directly. async def read_from_reduct(t1, t2): async with ReductClient( CONNECTION_REDUCT, api_token="reductstore" ) as reduct_client: count = 0 bucket = await reduct_client.get_bucket("benchmark") async for rec in bucket.query("data", t1, t2, ttl=90): count += len(await rec.read_all()) return count