From 64289ce6d5cee58c2ade0aebdd90f91a0a47308a Mon Sep 17 00:00:00 2001 From: Jerry <61386381+JunJie-GitHub@users.noreply.github.com> Date: Thu, 19 Dec 2024 04:30:39 +0800 Subject: [PATCH] Fix mysql advanced sync rule execute error (#3044) Co-authored-by: Li Junjie <5278012li@gmail.com> Co-authored-by: Sean Story --- connectors/sources/mysql.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connectors/sources/mysql.py b/connectors/sources/mysql.py index 9dfc236d6..edc455533 100644 --- a/connectors/sources/mysql.py +++ b/connectors/sources/mysql.py @@ -638,7 +638,7 @@ async def _yield_docs_custom_query(self, client, tables, query, id_columns): ) return - async for row in client.yield_rows_for_query(query): + async for row in client.yield_rows_for_query(query, primary_key_columns): yield row2doc( row=row, column_names=column_names,