AsyncPoeApi TypeError: object dict can't be used in 'await' expression"

[cherishleon]

I have a problem when I try to use asynchronous calls to the api.

import asyncio
from poe_api_wrapper import AsyncPoeApi
async def xx(client, row):
    answer = 
    async for chunk in client.send_message("", message, chatId=):

    return answer 

async def process_batch(client, rows, batch_size=5):
    tasks = []
    for row in rows:
        task = asyncio.create_task(xx(client, row))
        tasks.append(task)
    results = await asyncio.gather(*tasks)
    return results

async def process_dataframe(df, batch_size=5):
    client = await AsyncPoeApi(tokens=tokens).create()

     results = await process_batch(client, batch_rows, batch_size)
async def main1():
    batch_size = 1
    await process_dataframe(df, batch_size)

asyncio.run(main1())

---

TypeError Traceback (most recent call last)
Cell In[26], line 5
2 batch_size = 1
3 await process_dataframe(df, batch_size)
----> 5 asyncio.run(main1())

File d:\conda\lib\site-packages
est_asyncio.py:35, in _patch_asyncio..run(main, debug)
33 task = asyncio.ensure_future(main)
34 try:
---> 35 return loop.run_until_complete(task)
36 finally:
37 if not task.done():

File d:\conda\lib\site-packages
est_asyncio.py:90, in _patch_loop..run_until_complete(self, future)
87 if not f.done():
88 raise RuntimeError(
89 'Event loop stopped before Future completed.')
---> 90 return f.result()

File d:\conda\lib\asyncio\futures.py:201, in Future.result(self)
199 self.__log_traceback = False
200 if self._exception is not None:
--> 201 raise self._exception.with_traceback(self._exception_tb)
202 return self._result

File d:\conda\lib\asyncio\tasks.py:234, in Task.__step(failed resolving arguments)
232 result = coro.send(None)
233 else:
--> 234 result = coro.throw(exc)
235 except StopIteration as exc:
236 if self._must_cancel:
237 # Task is cancelled right before coro stops.

Cell In[26], line 3, in main1()
1 async def main1():
2 batch_size = 1
----> 3 await process_dataframe(df, batch_size)

Cell In[17], line 41, in process_dataframe(df, batch_size)
38 batch_rows = df.iloc[batch_start:batch_end].to_dict('records')
40 # try:
---> 41 results = await process_batch(client, batch_rows, batch_size)
43 for idx, result in enumerate(results):
44 df_idx = batch_start + idx

Cell In[17], line 20, in process_batch(client, rows, batch_size)
18 task = asyncio.create_task(translate(client, row))
19 tasks.append(task)
---> 20 results = await asyncio.gather(*tasks)
21 return results

File d:\conda\lib\asyncio\tasks.py:304, in Task.__wakeup(self, future)
302 def __wakeup(self, future):
303 try:
--> 304 future.result()
305 except BaseException as exc:
306 # This may also be a cancellation.
307 self.__step(exc)

File d:\conda\lib\asyncio\tasks.py:232, in Task.__step(failed resolving arguments)
228 try:
229 if exc is None:
230 # We use the send method directly, because coroutines
231 # don't have __iter__ and __next__ methods.
--> 232 result = coro.send(None)
233 else:
234 result = coro.throw(exc)

Cell In[17], line 9, in translate(client, row)
8 answer = ''
----> 9 async for chunk in client.send_message("", message, chatId=):

File d:\conda\lib\site-packages\poe_api_wrapper\async_api.py:930, in AsyncPoeApi.send_message(self, bot, message, chatId, chatCode, msgPrice, file_path, suggest_replies, timeout)
926 yield response
928 last_text = response["text"]
--> 930 await self.delete_queues(chatId)
931 self.retry_attempts = 3

File d:\conda\lib\site-packages\poe_api_wrapper\async_api.py:384, in AsyncPoeApi.delete_queues(self, chatId)
382 while not self.message_queues[chatId].empty():
383 try:
--> 384 await self.message_queues[chatId].get_nowait()
385 except asyncio.QueueEmpty:
386 pass

TypeError: object dict can't be used in 'await' expression"