From a05591a677d47aac213cf524b6a476753587f534 Mon Sep 17 00:00:00 2001 From: "junjie.li" Date: Tue, 17 Dec 2024 18:29:34 +0800 Subject: [PATCH] Fix mysql advanced sync rule execute error --- 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,