git commit -m "feat: repair core code"

Author: Mermaid97

backend/data_process/tasks.py

@@ -391,12 +391,6 @@ def forward(
                             cached, str) else str(type(cached))
                         logger.error(
                             f"[{self.request.id}] FORWARD TASK: JSON decode error for key '{redis_key}': {str(jde)}; raw_prefix={raw_preview!r}")
-                        # Try to clean up corrupted Redis data
-                        try:
-                            client.delete(redis_key)
-                            logger.info(f"[{self.request.id}] FORWARD TASK: Deleted corrupted Redis key '{redis_key}'")
-                        except Exception as cleanup_e:
-                            logger.warning(f"[{self.request.id}] FORWARD TASK: Failed to cleanup corrupted Redis key: {cleanup_e}")
                         raise
                 else:
                     # No busy-wait: release the worker slot and retry later

sdk/nexent/vector_database/elasticsearch_core.py

@@ -70,9 +70,8 @@ def __init__(
         self._settings_lock = threading.Lock()
         self._operation_counter = 0
 
-        # Embedding API limits - Conservative settings for stability
-        # Different APIs have different limits, so we use a conservative approach
-        self.max_texts_per_batch = 50   # Very conservative for stability
+        # Embedding API limits
+        self.max_texts_per_batch = 2048
         self.max_tokens_per_text = 8192
         self.max_total_tokens = 100000
         self.max_retries = 3  # Number of retries for failed embedding batches