diff --git a/api/db/services/connector_service.py b/api/db/services/connector_service.py
index c87f6056c..2ff16669d 100644
--- a/api/db/services/connector_service.py
+++ b/api/db/services/connector_service.py
@@ -236,13 +236,13 @@ class Connector2KbService(CommonService):
             conn_id = conn["id"]
             connector_ids.append(conn_id)
             if conn_id in old_conn_ids:
-                cls.update_by_id(conn_id, {"auto_parse": conn.get("auto_parse", "1")})
+                cls.filter_update([cls.model.connector_id==conn_id, cls.model.kb_id==kb_id], {"auto_parse": conn.get("auto_parse", "1")})
                 continue
             cls.save(**{
                 "id": get_uuid(),
                 "connector_id": conn_id,
                 "kb_id": kb_id,
-                "auto_parse": conn.get("auto_parse", "1")
+                "auto_parse": conn.get("auto_parse", "1")   
             })
             SyncLogsService.schedule(conn_id, kb_id, reindex=True)