The cursor.execute(self.mysql_query) holds my script?

[madpin]

Hello folks,

I have a question, I'm querying a very large table, 60M records, with 70 columns.
In my script, I'd like to read from MySQL and write to another DB.
But I don't want to paginate on the query, because of the quick changing in the table.

So, my idea was to have:

self.logger.debug("before await cursor.execute")
await cursor.execute(self.mysql_query)
self.logger.debug("after await cursor.execute")
while True:
    rows = await cursor.fetchmany(self.reader_page_size)

But the logger: "after await cursor.execute" only gets logged after the records been downloaded.

Can someone help me?

Thanks