Async read query

[varna9000]

Hi can you prove an example how to make async read query?

This works well writing data but I can't implement it for reading. I use this function:

async def read_record():
    reader = client.query_api()
    q='from(bucket:"my-bucket") |> range(start: -30m)'
    return asyncio.get_running_loop().run_in_executor(None, reader.query(q))

and I'm calling it with

result= await read_record()

however I get ValueError: [RuntimeError("await wasn't used with future"), TypeError('vars() argument must have __dict__ attribute')]

[varna9000]

Got it working with the following change to the function:

async def read_record():
    reader = client.query_api()
    q='from(bucket:"my-bucket") |> range(start: -30m)'
    return await asyncio.get_running_loop().run_in_executor(None, partial(reader.query, query=q))