Fix mysql advanced sync rule execute error (#3044)

Co-authored-by: Li Junjie <[email protected]> Co-authored-by: Sean Story <[email protected]>
elastic · Dec 18, 2024 · 64289ce · 64289ce
1 parent ec1ab8a
commit 64289ce
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,