How can i get data by chunks? Code: <div class="snippet-clipboar

Error when toggle stream_results=True about asynch HOT 2 OPEN

long2ice commented on August 15, 2024 1

Error when toggle stream_results=True

from asynch.

Comments (2)

bukata-sa commented on August 15, 2024

There are more problems with stream results than that
I faced problem here self.settings = self.settings or {}
Solved it that way:

collections_cursor.set_stream_results(True, 500000)
collections_cursor._settings = {"max_block_size": 500000}
collections_cursor.settings = collections_cursor._settings

Next error:

  File "/venv/lib/python3.8/site-packages/asynch/cursors.py", line 63, in execute
    response = await execute(query, args=args, with_column_types=True, **execute_kwargs)
TypeError: execute_iter() got an unexpected keyword argument 'args'

I tried to hide args param:

def fake_execute_iter(orig_method):
    async def do(
            query,
            args=None,
            params=None,
            with_column_types=False,
            external_tables=None,
            query_id=None,
            settings=None,
            types_check=False):
        return await orig_method(query, params, with_column_types, external_tables, query_id, settings, types_check)

    return do

Last exception got from here:

  File "/venv/lib/python3.8/site-packages/asynch/cursors.py", line 65, in execute
    self._process_response(response)
  File "/venv/lib/python3.8/site-packages/asynch/cursors.py", line 82, in _process_response
    columns_with_types = next(response)
  File "/venv/lib/python3.8/site-packages/asynch/proto/connection.py", line 857, in iter_receive_result
    for rows in IterQueryResult(gen, with_column_types=with_column_types):
  File "/venv/lib/python3.8/site-packages/asynch/proto/result.py", line 117, in next
    packet = next(self.packet_generator)
TypeError: 'async_generator' object is not an iterator

Haven't tried any further

from asynch.