From fee583a51332ab82184798df900b985b9696b5ba Mon Sep 17 00:00:00 2001
From: Li Junjie <5278012li@gmail.com>
Date: Tue, 17 Dec 2024 19:46:07 +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,