Fix mysql advanced sync rule execute error

elastic · Dec 17, 2024 · a05591a · a05591a
1 parent e304bd2
commit a05591a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,