Bug on get_batch_of_all function from the base class
The issue is that the connection is used to generate a cursor. With that type of use, it messes up other aspects of the connection.
In context, table_row_count = await self.get_row_count(con=con) would return None because the connection is moved.
The fix
Don't pass in the connection into the get_row_count. It is wrapped under an ensure_connection function. Meaning it will generate a new connection that will give the correct output.
Bug on
get_batch_of_allfunction from the base classThe issue is that the connection is used to generate a cursor. With that type of use, it messes up other aspects of the connection.
In context,
table_row_count = await self.get_row_count(con=con)would return None because the connection is moved.The fix
Don't pass in the connection into the
get_row_count. It is wrapped under anensure_connectionfunction. Meaning it will generate a new connection that will give the correct output.