fix(sdk): add cancel_all_task_of call in stop_parsing endpoint (#11748 )

## Problem The SDK API endpoint `DELETE /datasets/{dataset_id}/chunks` only updates database status but does not send cancellation signal via Redis, causing background parsing tasks to continue and eventually complete (status becomes DONE instead of CANCEL). ## Root Cause The SDK endpoint was missing the `cancel_all_task_of(id)` call that the web API ([api/apps/document_app.py](cci:7://file:///d:/workspace1/ragflow-admin/api/apps/document_app.py:0:0-0:0)) uses to properly stop background tasks. ## Solution Added `cancel_all_task_of(id)` call in the [stop_parsing](cci:1://file:///d:/workspace1/ragflow/api/apps/sdk/doc.py:785:0-855:23) function to send cancellation signal via Redis, consistent with the web API behavior. ## Related Issue Fixes #11745 Co-authored-by: tedhappy <tedhappy@users.noreply.github.com>
Feat: Display the ID of the code image in the dialog. #10427 (#11746 )
2025-12-06 07:19:03 +08:00 · 2025-12-04 19:29:06 +08:00 · 2025-12-04 18:49:55 +08:00 · 2025-12-04 18:49:32 +08:00 · 2025-12-04 18:49:13 +08:00 · 2025-12-04 17:28:03 +08:00
20 changed files with 388 additions and 556650 deletions
--- a/3
+++ b/3
@@ -10,11 +10,10 @@ WORKDIR /ragflow
 # Copy models downloaded via download_deps.py
 RUN mkdir -p /ragflow/rag/res/deepdoc /root/.ragflow
 RUN --mount=type=bind,from=infiniflow/ragflow_deps:latest,source=/huggingface.co,target=/huggingface.co \
-    cp /huggingface.co/InfiniFlow/huqie/huqie.txt.trie /ragflow/rag/res/ && \
    tar --exclude='.*' -cf - \
        /huggingface.co/InfiniFlow/text_concat_xgb_v1.0 \
        /huggingface.co/InfiniFlow/deepdoc \
-        | tar -xf - --strip-components=3 -C /ragflow/rag/res/deepdoc 
+        | tar -xf - --strip-components=3 -C /ragflow/rag/res/deepdoc

 # https://github.com/chrismattmann/tika-python
 # This is the only way to run python-tika without internet access. Without this set, the default is to check the tika version and pull latest every time from Apache.
--- a/api/apps/sdk/doc.py
+++ b/api/apps/sdk/doc.py
@@ -33,7 +33,7 @@ from api.db.services.file_service import FileService
 from api.db.services.knowledgebase_service import KnowledgebaseService
 from api.db.services.llm_service import LLMBundle
 from api.db.services.tenant_llm_service import TenantLLMService
-from api.db.services.task_service import TaskService, queue_tasks
+from api.db.services.task_service import TaskService, queue_tasks, cancel_all_task_of
 from api.db.services.dialog_service import meta_filter, convert_conditions
 from api.utils.api_utils import check_duplicate_ids, construct_json_result, get_error_data_result, get_parser_config, get_result, server_error_response, token_required, \
    get_request_json
@@ -835,6 +835,8 @@ async def stop_parsing(tenant_id, dataset_id):
            return get_error_data_result(message=f"You don't own the document {id}.")
        if int(doc[0].progress) == 1 or doc[0].progress == 0:
            return get_error_data_result("Can't stop parsing document with progress at 0 or 1")
+        # Send cancellation signal via Redis to stop background task
+        cancel_all_task_of(id)
        info = {"run": "2", "progress": 0, "chunk_num": 0}
        DocumentService.update_by_id(id, info)
        settings.docStoreConn.delete({"doc_id": doc[0].id}, search.index_name(tenant_id), dataset_id)
--- a/docker/docker-compose-CN-oc9.yml
+++ b/docker/docker-compose-CN-oc9.yml
@@ -23,7 +23,7 @@ services:
    env_file: .env
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
    # If you're using Docker Desktop, the --add-host flag is optional. This flag makes sure that the host's internal IP gets exposed to the Prometheus container.
    extra_hosts:
@@ -48,7 +48,7 @@ services:
    env_file: .env
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
    # If you're using Docker Desktop, the --add-host flag is optional. This flag makes sure that the host's internal IP gets exposed to the Prometheus container.
    extra_hosts:
--- a/docker/docker-compose-base.yml
+++ b/docker/docker-compose-base.yml
@@ -31,7 +31,7 @@ services:
      retries: 120
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped

  opensearch01:
    profiles:
@@ -67,12 +67,12 @@ services:
      retries: 120
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped

  infinity:
    profiles:
      - infinity
-    image: infiniflow/infinity:v0.6.8
+    image: infiniflow/infinity:v0.6.10
    volumes:
      - infinity_data:/var/infinity
      - ./infinity_conf.toml:/infinity_conf.toml
@@ -94,7 +94,7 @@ services:
      interval: 10s
      timeout: 10s
      retries: 120
-    restart: on-failure
+    restart: unless-stopped

  oceanbase:
    profiles:
@@ -119,7 +119,7 @@ services:
      timeout: 10s
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped

  sandbox-executor-manager:
    profiles:
@@ -147,7 +147,7 @@ services:
      interval: 10s
      timeout: 10s
      retries: 120
-    restart: on-failure
+    restart: unless-stopped

  mysql:
    # mysql:5.7 linux/arm64 image is unavailable.
@@ -175,7 +175,7 @@ services:
      interval: 10s
      timeout: 10s
      retries: 120
-    restart: on-failure
+    restart: unless-stopped

  minio:
    image: quay.io/minio/minio:RELEASE.2025-06-13T11-33-47Z
@@ -191,7 +191,7 @@ services:
      - minio_data:/data
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    healthcheck:
      test: ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]
      interval: 10s
@@ -209,7 +209,7 @@ services:
      - redis_data:/data
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    healthcheck:
      test: ["CMD", "redis-cli", "-a", "${REDIS_PASSWORD}", "ping"]
      interval: 10s
@@ -228,7 +228,7 @@ services:
    networks:
      - ragflow
    command: ["--model-id", "/data/${TEI_MODEL}", "--auto-truncate"]
-    restart: on-failure
+    restart: unless-stopped


  tei-gpu:
@@ -249,7 +249,7 @@ services:
            - driver: nvidia
              count: all
              capabilities: [gpu]
-    restart: on-failure
+    restart: unless-stopped


  kibana:
@@ -271,7 +271,7 @@ services:
      retries: 120
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped


 volumes:
--- a/docker/docker-compose-macos.yml
+++ b/docker/docker-compose-macos.yml
@@ -22,7 +22,7 @@ services:
    env_file: .env
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
    # If you're using Docker Desktop, the --add-host flag is optional. This flag makes sure that the host's internal IP gets exposed to the Prometheus container.
    extra_hosts:
@@ -39,7 +39,7 @@ services:
  #   entrypoint: "/ragflow/entrypoint_task_executor.sh 1 3"
  #   networks:
  #     - ragflow
-  #   restart: on-failure
+  #   restart: unless-stopped
  #   # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
  #   # If you're using Docker Desktop, the --add-host flag is optional. This flag makes sure that the host's internal IP gets exposed to the Prometheus container.
  #   extra_hosts:
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -45,7 +45,7 @@ services:
    env_file: .env
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
    # If you use Docker Desktop, the --add-host flag is optional. This flag ensures that the host's internal IP is exposed to the Prometheus container.
    extra_hosts:
@@ -94,7 +94,7 @@ services:
    env_file: .env
    networks:
      - ragflow
-    restart: on-failure
+    restart: unless-stopped
    # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
    # If you use Docker Desktop, the --add-host flag is optional. This flag ensures that the host's internal IP is exposed to the Prometheus container.
    extra_hosts:
@@ -120,7 +120,7 @@ services:
  #   entrypoint: "/ragflow/entrypoint_task_executor.sh 1 3"
  #   networks:
  #     - ragflow
-  #   restart: on-failure
+  #   restart: unless-stopped
  #   # https://docs.docker.com/engine/daemon/prometheus/#create-a-prometheus-configuration
  #   # If you're using Docker Desktop, the --add-host flag is optional. This flag makes sure that the host's internal IP gets exposed to the Prometheus container.
  #   extra_hosts:
--- a/docker/infinity_conf.toml
+++ b/docker/infinity_conf.toml
@@ -1,5 +1,5 @@
 [general]
-version                  = "0.6.8"
+version                  = "0.6.10"
 time_zone                = "utc-8"

 [network]
--- a/docs/references/http_api_reference.md
+++ b/docs/references/http_api_reference.md
@@ -512,13 +512,16 @@ curl --request POST \
      - Maximum: `2048`
    - `"delimiter"`: `string`
      - Defaults to `"\n"`.
-    - `"html4excel"`: `bool` Indicates whether to convert Excel documents into HTML format.
+    - `"html4excel"`: `bool`
+      - Whether to convert Excel documents into HTML format.
      - Defaults to `false`
    - `"layout_recognize"`: `string`
      - Defaults to `DeepDOC`
-    - `"tag_kb_ids"`: `array<string>` refer to [Use tag set](https://ragflow.io/docs/dev/use_tag_sets)
-      - Must include a list of dataset IDs, where each dataset is parsed using the Tag Chunking Method
-    - `"task_page_size"`: `int` For PDF only.
+    - `"tag_kb_ids"`: `array<string>`
+      - IDs of datasets to be parsed using the Tag chunk method.
+      - Before setting this, ensure a tag set is created and properly configured. For details, see [Use tag set](https://ragflow.io/docs/dev/use_tag_sets).
+    - `"task_page_size"`: `int`
+      - For PDFs only.
      - Defaults to `12`
      - Minimum: `1`
    - `"raptor"`: `object` RAPTOR-specific settings.
--- a/download_deps.py
+++ b/download_deps.py
@@ -43,7 +43,6 @@ def get_urls(use_china_mirrors=False) -> list[Union[str, list[str]]]:
 repos = [
    "InfiniFlow/text_concat_xgb_v1.0",
    "InfiniFlow/deepdoc",
-    "InfiniFlow/huqie",
 ]


--- a/helm/values.yaml
+++ b/helm/values.yaml
@@ -96,7 +96,7 @@ ragflow:
 infinity:
  image:
    repository: infiniflow/infinity
-    tag: v0.6.8
+    tag: v0.6.10
    pullPolicy: IfNotPresent
    pullSecrets: []
  storage:
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -49,7 +49,7 @@ dependencies = [
    "html-text==0.6.2",
    "httpx[socks]>=0.28.1,<0.29.0",
    "huggingface-hub>=0.25.0,<0.26.0",
-    "infinity-sdk==0.6.8",
+    "infinity-sdk==0.6.10",
    "infinity-emb>=0.0.66,<0.0.67",
    "itsdangerous==2.1.2",
    "json-repair==0.35.0",
--- a/rag/res/huqie.txt
+++ b/rag/res/huqie.txt
--- a/rag/svr/sync_data_source.py
+++ b/rag/svr/sync_data_source.py
@@ -157,11 +157,30 @@ class Confluence(SyncBase):
        from common.data_source.config import DocumentSource
        from common.data_source.interfaces import StaticCredentialsProvider

+        index_mode = (self.conf.get("index_mode") or "everything").lower()
+        if index_mode not in {"everything", "space", "page"}:
+            index_mode = "everything"
+
+        space = ""
+        page_id = ""
+
+        index_recursively = False
+        if index_mode == "space":
+            space = (self.conf.get("space") or "").strip()
+            if not space:
+                raise ValueError("Space Key is required when indexing a specific Confluence space.")
+        elif index_mode == "page":
+            page_id = (self.conf.get("page_id") or "").strip()
+            if not page_id:
+                raise ValueError("Page ID is required when indexing a specific Confluence page.")
+            index_recursively = bool(self.conf.get("index_recursively", False))
+
        self.connector = ConfluenceConnector(
            wiki_base=self.conf["wiki_base"],
-            space=self.conf.get("space", ""),
            is_cloud=self.conf.get("is_cloud", True),
-            # page_id=self.conf.get("page_id", ""),
+            space=space,
+            page_id=page_id,
+            index_recursively=index_recursively,
        )

        credentials_provider = StaticCredentialsProvider(tenant_id=task["tenant_id"], connector_name=DocumentSource.CONFLUENCE, credential_json=self.conf["credentials"])
--- a/test/unit_test/services/test_evaluation_framework_demo.py
+++ b/test/unit_test/services/test_evaluation_framework_demo.py
@@ -1,323 +0,0 @@
-#
-#  Copyright 2025 The InfiniFlow Authors. All Rights Reserved.
-#
-#  Licensed under the Apache License, Version 2.0 (the "License");
-#  you may not use this file except in compliance with the License.
-#  You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-#
-
-"""
-Standalone test to demonstrate the RAG evaluation test framework works.
-This test doesn't require RAGFlow dependencies.
-"""
-
-import pytest
-from unittest.mock import Mock
-
-
-class TestEvaluationFrameworkDemo:
-    """Demo tests to verify the evaluation test framework is working"""
-
-    def test_basic_assertion(self):
-        """Test basic assertion works"""
-        assert 1 + 1 == 2
-
-    def test_mock_evaluation_service(self):
-        """Test mocking evaluation service"""
-        mock_service = Mock()
-        mock_service.create_dataset.return_value = (True, "dataset_123")
-        
-        success, dataset_id = mock_service.create_dataset(
-            name="Test Dataset",
-            kb_ids=["kb_1"]
-        )
-        
-        assert success is True
-        assert dataset_id == "dataset_123"
-        mock_service.create_dataset.assert_called_once()
-
-    def test_mock_test_case_addition(self):
-        """Test mocking test case addition"""
-        mock_service = Mock()
-        mock_service.add_test_case.return_value = (True, "case_123")
-        
-        success, case_id = mock_service.add_test_case(
-            dataset_id="dataset_123",
-            question="Test question?",
-            reference_answer="Test answer"
-        )
-        
-        assert success is True
-        assert case_id == "case_123"
-
-    def test_mock_evaluation_run(self):
-        """Test mocking evaluation run"""
-        mock_service = Mock()
-        mock_service.start_evaluation.return_value = (True, "run_123")
-        
-        success, run_id = mock_service.start_evaluation(
-            dataset_id="dataset_123",
-            dialog_id="dialog_456",
-            user_id="user_1"
-        )
-        
-        assert success is True
-        assert run_id == "run_123"
-
-    def test_mock_metrics_computation(self):
-        """Test mocking metrics computation"""
-        mock_service = Mock()
-        
-        # Mock retrieval metrics
-        metrics = {
-            "precision": 0.85,
-            "recall": 0.78,
-            "f1_score": 0.81,
-            "hit_rate": 1.0,
-            "mrr": 0.9
-        }
-        mock_service._compute_retrieval_metrics.return_value = metrics
-        
-        result = mock_service._compute_retrieval_metrics(
-            retrieved_ids=["chunk_1", "chunk_2", "chunk_3"],
-            relevant_ids=["chunk_1", "chunk_2", "chunk_4"]
-        )
-        
-        assert result["precision"] == 0.85
-        assert result["recall"] == 0.78
-        assert result["f1_score"] == 0.81
-
-    def test_mock_recommendations(self):
-        """Test mocking recommendations"""
-        mock_service = Mock()
-        
-        recommendations = [
-            {
-                "issue": "Low Precision",
-                "severity": "high",
-                "suggestions": [
-                    "Increase similarity_threshold",
-                    "Enable reranking"
-                ]
-            }
-        ]
-        mock_service.get_recommendations.return_value = recommendations
-        
-        recs = mock_service.get_recommendations("run_123")
-        
-        assert len(recs) == 1
-        assert recs[0]["issue"] == "Low Precision"
-        assert len(recs[0]["suggestions"]) == 2
-
-    @pytest.mark.parametrize("precision,recall,expected_f1", [
-        (1.0, 1.0, 1.0),
-        (0.8, 0.6, 0.69),
-        (0.5, 0.5, 0.5),
-        (0.0, 0.0, 0.0),
-    ])
-    def test_f1_score_calculation(self, precision, recall, expected_f1):
-        """Test F1 score calculation with different inputs"""
-        if precision + recall > 0:
-            f1 = 2 * (precision * recall) / (precision + recall)
-        else:
-            f1 = 0.0
-        
-        assert abs(f1 - expected_f1) < 0.01
-
-    def test_dataset_list_structure(self):
-        """Test dataset list structure"""
-        mock_service = Mock()
-        
-        expected_result = {
-            "total": 3,
-            "datasets": [
-                {"id": "dataset_1", "name": "Dataset 1"},
-                {"id": "dataset_2", "name": "Dataset 2"},
-                {"id": "dataset_3", "name": "Dataset 3"}
-            ]
-        }
-        mock_service.list_datasets.return_value = expected_result
-        
-        result = mock_service.list_datasets(
-            tenant_id="tenant_1",
-            user_id="user_1",
-            page=1,
-            page_size=10
-        )
-        
-        assert result["total"] == 3
-        assert len(result["datasets"]) == 3
-        assert result["datasets"][0]["id"] == "dataset_1"
-
-    def test_evaluation_run_status_flow(self):
-        """Test evaluation run status transitions"""
-        mock_service = Mock()
-        
-        # Simulate status progression
-        statuses = ["PENDING", "RUNNING", "COMPLETED"]
-        
-        for status in statuses:
-            mock_run = {"id": "run_123", "status": status}
-            mock_service.get_run_results.return_value = {"run": mock_run}
-            
-            result = mock_service.get_run_results("run_123")
-            assert result["run"]["status"] == status
-
-    def test_bulk_import_success_count(self):
-        """Test bulk import success/failure counting"""
-        mock_service = Mock()
-        
-        # Simulate 8 successes, 2 failures
-        mock_service.import_test_cases.return_value = (8, 2)
-        
-        success_count, failure_count = mock_service.import_test_cases(
-            dataset_id="dataset_123",
-            cases=[{"question": f"Q{i}"} for i in range(10)]
-        )
-        
-        assert success_count == 8
-        assert failure_count == 2
-        assert success_count + failure_count == 10
-
-    def test_metrics_summary_aggregation(self):
-        """Test metrics summary aggregation"""
-        results = [
-            {"metrics": {"precision": 0.9, "recall": 0.8}, "execution_time": 1.2},
-            {"metrics": {"precision": 0.8, "recall": 0.7}, "execution_time": 1.5},
-            {"metrics": {"precision": 0.85, "recall": 0.75}, "execution_time": 1.3}
-        ]
-        
-        # Calculate averages
-        avg_precision = sum(r["metrics"]["precision"] for r in results) / len(results)
-        avg_recall = sum(r["metrics"]["recall"] for r in results) / len(results)
-        avg_time = sum(r["execution_time"] for r in results) / len(results)
-        
-        assert abs(avg_precision - 0.85) < 0.01
-        assert abs(avg_recall - 0.75) < 0.01
-        assert abs(avg_time - 1.33) < 0.01
-
-    def test_recommendation_severity_levels(self):
-        """Test recommendation severity levels"""
-        severities = ["low", "medium", "high", "critical"]
-        
-        for severity in severities:
-            rec = {
-                "issue": "Test Issue",
-                "severity": severity,
-                "suggestions": ["Fix it"]
-            }
-            assert rec["severity"] in severities
-
-    def test_empty_dataset_handling(self):
-        """Test handling of empty datasets"""
-        mock_service = Mock()
-        mock_service.get_test_cases.return_value = []
-        
-        cases = mock_service.get_test_cases("empty_dataset")
-        
-        assert len(cases) == 0
-        assert isinstance(cases, list)
-
-    def test_error_handling(self):
-        """Test error handling in service"""
-        mock_service = Mock()
-        mock_service.create_dataset.return_value = (False, "Dataset name cannot be empty")
-        
-        success, error = mock_service.create_dataset(name="", kb_ids=[])
-        
-        assert success is False
-        assert "empty" in error.lower()
-
-    def test_pagination_logic(self):
-        """Test pagination logic"""
-        total_items = 50
-        page_size = 10
-        page = 2
-        
-        # Calculate expected items for page 2
-        start = (page - 1) * page_size
-        end = min(start + page_size, total_items)
-        expected_count = end - start
-        
-        assert expected_count == 10
-        assert start == 10
-        assert end == 20
-
-
-class TestMetricsCalculations:
-    """Test metric calculation logic"""
-
-    def test_precision_calculation(self):
-        """Test precision calculation"""
-        retrieved = {"chunk_1", "chunk_2", "chunk_3", "chunk_4"}
-        relevant = {"chunk_1", "chunk_2", "chunk_5"}
-        
-        precision = len(retrieved & relevant) / len(retrieved)
-        
-        assert precision == 0.5  # 2 out of 4
-
-    def test_recall_calculation(self):
-        """Test recall calculation"""
-        retrieved = {"chunk_1", "chunk_2", "chunk_3", "chunk_4"}
-        relevant = {"chunk_1", "chunk_2", "chunk_5"}
-        
-        recall = len(retrieved & relevant) / len(relevant)
-        
-        assert abs(recall - 0.67) < 0.01  # 2 out of 3
-
-    def test_hit_rate_positive(self):
-        """Test hit rate when relevant chunk is found"""
-        retrieved = {"chunk_1", "chunk_2", "chunk_3"}
-        relevant = {"chunk_2", "chunk_4"}
-        
-        hit_rate = 1.0 if (retrieved & relevant) else 0.0
-        
-        assert hit_rate == 1.0
-
-    def test_hit_rate_negative(self):
-        """Test hit rate when no relevant chunk is found"""
-        retrieved = {"chunk_1", "chunk_2", "chunk_3"}
-        relevant = {"chunk_4", "chunk_5"}
-        
-        hit_rate = 1.0 if (retrieved & relevant) else 0.0
-        
-        assert hit_rate == 0.0
-
-    def test_mrr_calculation(self):
-        """Test MRR calculation"""
-        retrieved_ids = ["chunk_1", "chunk_2", "chunk_3", "chunk_4"]
-        relevant_ids = {"chunk_3", "chunk_5"}
-        
-        mrr = 0.0
-        for i, chunk_id in enumerate(retrieved_ids, 1):
-            if chunk_id in relevant_ids:
-                mrr = 1.0 / i
-                break
-        
-        assert abs(mrr - 0.33) < 0.01  # First relevant at position 3
-
-
-# Summary test
-def test_evaluation_framework_summary():
-    """
-    Summary test to confirm all evaluation framework features work.
-    This test verifies that:
-    - Basic assertions work
-    - Mocking works for all service methods
-    - Metrics calculations are correct
-    - Error handling works
-    - Pagination logic works
-    """
-    assert True, "Evaluation test framework is working correctly!"
-
-
-if __name__ == "__main__":
-    pytest.main([__file__, "-v"])
--- a/test/unit_test/services/test_evaluation_service.py
+++ b/test/unit_test/services/test_evaluation_service.py
@@ -1,557 +0,0 @@
-#
-#  Copyright 2025 The InfiniFlow Authors. All Rights Reserved.
-#
-#  Licensed under the Apache License, Version 2.0 (the "License");
-#  you may not use this file except in compliance with the License.
-#  You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-#
-
-"""
-Unit tests for RAG Evaluation Service
-
-Tests cover:
- Dataset management (CRUD operations)
- Test case management
- Evaluation execution
- Metrics computation
- Recommendations generation
-"""
-
-import pytest
-from unittest.mock import patch
-
-
-class TestEvaluationDatasetManagement:
-    """Tests for evaluation dataset management"""
-    
-    @pytest.fixture
-    def mock_evaluation_service(self):
-        """Create a mock EvaluationService"""
-        with patch('api.db.services.evaluation_service.EvaluationService') as mock:
-            yield mock
-    
-    @pytest.fixture
-    def sample_dataset_data(self):
-        """Sample dataset data for testing"""
-        return {
-            "name": "Customer Support QA",
-            "description": "Test cases for customer support",
-            "kb_ids": ["kb_123", "kb_456"],
-            "tenant_id": "tenant_1",
-            "user_id": "user_1"
-        }
-    
-    def test_create_dataset_success(self, mock_evaluation_service, sample_dataset_data):
-        """Test successful dataset creation"""
-        mock_evaluation_service.create_dataset.return_value = (True, "dataset_123")
-        
-        success, dataset_id = mock_evaluation_service.create_dataset(**sample_dataset_data)
-        
-        assert success is True
-        assert dataset_id == "dataset_123"
-        mock_evaluation_service.create_dataset.assert_called_once()
-    
-    def test_create_dataset_with_empty_name(self, mock_evaluation_service):
-        """Test dataset creation with empty name"""
-        data = {
-            "name": "",
-            "description": "Test",
-            "kb_ids": ["kb_123"],
-            "tenant_id": "tenant_1",
-            "user_id": "user_1"
-        }
-        
-        mock_evaluation_service.create_dataset.return_value = (False, "Dataset name cannot be empty")
-        success, error = mock_evaluation_service.create_dataset(**data)
-        
-        assert success is False
-        assert "name" in error.lower() or "empty" in error.lower()
-    
-    def test_create_dataset_with_empty_kb_ids(self, mock_evaluation_service):
-        """Test dataset creation with empty kb_ids"""
-        data = {
-            "name": "Test Dataset",
-            "description": "Test",
-            "kb_ids": [],
-            "tenant_id": "tenant_1",
-            "user_id": "user_1"
-        }
-        
-        mock_evaluation_service.create_dataset.return_value = (False, "kb_ids cannot be empty")
-        success, error = mock_evaluation_service.create_dataset(**data)
-        
-        assert success is False
-    
-    def test_get_dataset_success(self, mock_evaluation_service):
-        """Test successful dataset retrieval"""
-        expected_dataset = {
-            "id": "dataset_123",
-            "name": "Test Dataset",
-            "kb_ids": ["kb_123"]
-        }
-        mock_evaluation_service.get_dataset.return_value = expected_dataset
-        
-        dataset = mock_evaluation_service.get_dataset("dataset_123")
-        
-        assert dataset is not None
-        assert dataset["id"] == "dataset_123"
-    
-    def test_get_dataset_not_found(self, mock_evaluation_service):
-        """Test getting non-existent dataset"""
-        mock_evaluation_service.get_dataset.return_value = None
-        
-        dataset = mock_evaluation_service.get_dataset("nonexistent")
-        
-        assert dataset is None
-    
-    def test_list_datasets(self, mock_evaluation_service):
-        """Test listing datasets"""
-        expected_result = {
-            "total": 2,
-            "datasets": [
-                {"id": "dataset_1", "name": "Dataset 1"},
-                {"id": "dataset_2", "name": "Dataset 2"}
-            ]
-        }
-        mock_evaluation_service.list_datasets.return_value = expected_result
-        
-        result = mock_evaluation_service.list_datasets(
-            tenant_id="tenant_1",
-            user_id="user_1",
-            page=1,
-            page_size=20
-        )
-        
-        assert result["total"] == 2
-        assert len(result["datasets"]) == 2
-    
-    def test_list_datasets_with_pagination(self, mock_evaluation_service):
-        """Test listing datasets with pagination"""
-        mock_evaluation_service.list_datasets.return_value = {
-            "total": 50,
-            "datasets": [{"id": f"dataset_{i}"} for i in range(10)]
-        }
-        
-        result = mock_evaluation_service.list_datasets(
-            tenant_id="tenant_1",
-            user_id="user_1",
-            page=2,
-            page_size=10
-        )
-        
-        assert result["total"] == 50
-        assert len(result["datasets"]) == 10
-    
-    def test_update_dataset_success(self, mock_evaluation_service):
-        """Test successful dataset update"""
-        mock_evaluation_service.update_dataset.return_value = True
-        
-        success = mock_evaluation_service.update_dataset(
-            "dataset_123",
-            name="Updated Name",
-            description="Updated Description"
-        )
-        
-        assert success is True
-    
-    def test_update_dataset_not_found(self, mock_evaluation_service):
-        """Test updating non-existent dataset"""
-        mock_evaluation_service.update_dataset.return_value = False
-        
-        success = mock_evaluation_service.update_dataset(
-            "nonexistent",
-            name="Updated Name"
-        )
-        
-        assert success is False
-    
-    def test_delete_dataset_success(self, mock_evaluation_service):
-        """Test successful dataset deletion"""
-        mock_evaluation_service.delete_dataset.return_value = True
-        
-        success = mock_evaluation_service.delete_dataset("dataset_123")
-        
-        assert success is True
-    
-    def test_delete_dataset_not_found(self, mock_evaluation_service):
-        """Test deleting non-existent dataset"""
-        mock_evaluation_service.delete_dataset.return_value = False
-        
-        success = mock_evaluation_service.delete_dataset("nonexistent")
-        
-        assert success is False
-
-
-class TestEvaluationTestCaseManagement:
-    """Tests for test case management"""
-    
-    @pytest.fixture
-    def mock_evaluation_service(self):
-        """Create a mock EvaluationService"""
-        with patch('api.db.services.evaluation_service.EvaluationService') as mock:
-            yield mock
-    
-    @pytest.fixture
-    def sample_test_case(self):
-        """Sample test case data"""
-        return {
-            "dataset_id": "dataset_123",
-            "question": "How do I reset my password?",
-            "reference_answer": "Click on 'Forgot Password' and follow the email instructions.",
-            "relevant_doc_ids": ["doc_789"],
-            "relevant_chunk_ids": ["chunk_101", "chunk_102"]
-        }
-    
-    def test_add_test_case_success(self, mock_evaluation_service, sample_test_case):
-        """Test successful test case addition"""
-        mock_evaluation_service.add_test_case.return_value = (True, "case_123")
-        
-        success, case_id = mock_evaluation_service.add_test_case(**sample_test_case)
-        
-        assert success is True
-        assert case_id == "case_123"
-    
-    def test_add_test_case_with_empty_question(self, mock_evaluation_service):
-        """Test adding test case with empty question"""
-        mock_evaluation_service.add_test_case.return_value = (False, "Question cannot be empty")
-        
-        success, error = mock_evaluation_service.add_test_case(
-            dataset_id="dataset_123",
-            question=""
-        )
-        
-        assert success is False
-        assert "question" in error.lower() or "empty" in error.lower()
-    
-    def test_add_test_case_without_reference_answer(self, mock_evaluation_service):
-        """Test adding test case without reference answer (optional)"""
-        mock_evaluation_service.add_test_case.return_value = (True, "case_123")
-        
-        success, case_id = mock_evaluation_service.add_test_case(
-            dataset_id="dataset_123",
-            question="Test question",
-            reference_answer=None
-        )
-        
-        assert success is True
-    
-    def test_get_test_cases(self, mock_evaluation_service):
-        """Test getting all test cases for a dataset"""
-        expected_cases = [
-            {"id": "case_1", "question": "Question 1"},
-            {"id": "case_2", "question": "Question 2"}
-        ]
-        mock_evaluation_service.get_test_cases.return_value = expected_cases
-        
-        cases = mock_evaluation_service.get_test_cases("dataset_123")
-        
-        assert len(cases) == 2
-        assert cases[0]["id"] == "case_1"
-    
-    def test_get_test_cases_empty_dataset(self, mock_evaluation_service):
-        """Test getting test cases from empty dataset"""
-        mock_evaluation_service.get_test_cases.return_value = []
-        
-        cases = mock_evaluation_service.get_test_cases("dataset_123")
-        
-        assert len(cases) == 0
-    
-    def test_delete_test_case_success(self, mock_evaluation_service):
-        """Test successful test case deletion"""
-        mock_evaluation_service.delete_test_case.return_value = True
-        
-        success = mock_evaluation_service.delete_test_case("case_123")
-        
-        assert success is True
-    
-    def test_import_test_cases_success(self, mock_evaluation_service):
-        """Test bulk import of test cases"""
-        cases = [
-            {"question": "Question 1", "reference_answer": "Answer 1"},
-            {"question": "Question 2", "reference_answer": "Answer 2"},
-            {"question": "Question 3", "reference_answer": "Answer 3"}
-        ]
-        mock_evaluation_service.import_test_cases.return_value = (3, 0)
-        
-        success_count, failure_count = mock_evaluation_service.import_test_cases(
-            "dataset_123",
-            cases
-        )
-        
-        assert success_count == 3
-        assert failure_count == 0
-    
-    def test_import_test_cases_with_failures(self, mock_evaluation_service):
-        """Test bulk import with some failures"""
-        cases = [
-            {"question": "Question 1"},
-            {"question": ""},  # Invalid
-            {"question": "Question 3"}
-        ]
-        mock_evaluation_service.import_test_cases.return_value = (2, 1)
-        
-        success_count, failure_count = mock_evaluation_service.import_test_cases(
-            "dataset_123",
-            cases
-        )
-        
-        assert success_count == 2
-        assert failure_count == 1
-
-
-class TestEvaluationExecution:
-    """Tests for evaluation execution"""
-    
-    @pytest.fixture
-    def mock_evaluation_service(self):
-        """Create a mock EvaluationService"""
-        with patch('api.db.services.evaluation_service.EvaluationService') as mock:
-            yield mock
-    
-    def test_start_evaluation_success(self, mock_evaluation_service):
-        """Test successful evaluation start"""
-        mock_evaluation_service.start_evaluation.return_value = (True, "run_123")
-        
-        success, run_id = mock_evaluation_service.start_evaluation(
-            dataset_id="dataset_123",
-            dialog_id="dialog_456",
-            user_id="user_1"
-        )
-        
-        assert success is True
-        assert run_id == "run_123"
-    
-    def test_start_evaluation_with_invalid_dialog(self, mock_evaluation_service):
-        """Test starting evaluation with invalid dialog"""
-        mock_evaluation_service.start_evaluation.return_value = (False, "Dialog not found")
-        
-        success, error = mock_evaluation_service.start_evaluation(
-            dataset_id="dataset_123",
-            dialog_id="nonexistent",
-            user_id="user_1"
-        )
-        
-        assert success is False
-        assert "dialog" in error.lower()
-    
-    def test_start_evaluation_with_custom_name(self, mock_evaluation_service):
-        """Test starting evaluation with custom name"""
-        mock_evaluation_service.start_evaluation.return_value = (True, "run_123")
-        
-        success, run_id = mock_evaluation_service.start_evaluation(
-            dataset_id="dataset_123",
-            dialog_id="dialog_456",
-            user_id="user_1",
-            name="My Custom Evaluation"
-        )
-        
-        assert success is True
-    
-    def test_get_run_results(self, mock_evaluation_service):
-        """Test getting evaluation run results"""
-        expected_results = {
-            "run": {
-                "id": "run_123",
-                "status": "COMPLETED",
-                "metrics_summary": {
-                    "avg_precision": 0.85,
-                    "avg_recall": 0.78
-                }
-            },
-            "results": [
-                {"case_id": "case_1", "metrics": {"precision": 0.9}},
-                {"case_id": "case_2", "metrics": {"precision": 0.8}}
-            ]
-        }
-        mock_evaluation_service.get_run_results.return_value = expected_results
-        
-        results = mock_evaluation_service.get_run_results("run_123")
-        
-        assert results["run"]["id"] == "run_123"
-        assert len(results["results"]) == 2
-    
-    def test_get_run_results_not_found(self, mock_evaluation_service):
-        """Test getting results for non-existent run"""
-        mock_evaluation_service.get_run_results.return_value = {}
-        
-        results = mock_evaluation_service.get_run_results("nonexistent")
-        
-        assert results == {}
-
-
-class TestEvaluationMetrics:
-    """Tests for metrics computation"""
-    
-    @pytest.fixture
-    def mock_evaluation_service(self):
-        """Create a mock EvaluationService"""
-        with patch('api.db.services.evaluation_service.EvaluationService') as mock:
-            yield mock
-    
-    def test_compute_retrieval_metrics_perfect_match(self, mock_evaluation_service):
-        """Test retrieval metrics with perfect match"""
-        retrieved_ids = ["chunk_1", "chunk_2", "chunk_3"]
-        relevant_ids = ["chunk_1", "chunk_2", "chunk_3"]
-        
-        expected_metrics = {
-            "precision": 1.0,
-            "recall": 1.0,
-            "f1_score": 1.0,
-            "hit_rate": 1.0,
-            "mrr": 1.0
-        }
-        mock_evaluation_service._compute_retrieval_metrics.return_value = expected_metrics
-        
-        metrics = mock_evaluation_service._compute_retrieval_metrics(retrieved_ids, relevant_ids)
-        
-        assert metrics["precision"] == 1.0
-        assert metrics["recall"] == 1.0
-        assert metrics["f1_score"] == 1.0
-    
-    def test_compute_retrieval_metrics_partial_match(self, mock_evaluation_service):
-        """Test retrieval metrics with partial match"""
-        retrieved_ids = ["chunk_1", "chunk_2", "chunk_4", "chunk_5"]
-        relevant_ids = ["chunk_1", "chunk_2", "chunk_3"]
-        
-        expected_metrics = {
-            "precision": 0.5,  # 2 out of 4 retrieved are relevant
-            "recall": 0.67,    # 2 out of 3 relevant were retrieved
-            "f1_score": 0.57,
-            "hit_rate": 1.0,   # At least one relevant was retrieved
-            "mrr": 1.0         # First retrieved is relevant
-        }
-        mock_evaluation_service._compute_retrieval_metrics.return_value = expected_metrics
-        
-        metrics = mock_evaluation_service._compute_retrieval_metrics(retrieved_ids, relevant_ids)
-        
-        assert metrics["precision"] < 1.0
-        assert metrics["recall"] < 1.0
-        assert metrics["hit_rate"] == 1.0
-    
-    def test_compute_retrieval_metrics_no_match(self, mock_evaluation_service):
-        """Test retrieval metrics with no match"""
-        retrieved_ids = ["chunk_4", "chunk_5", "chunk_6"]
-        relevant_ids = ["chunk_1", "chunk_2", "chunk_3"]
-        
-        expected_metrics = {
-            "precision": 0.0,
-            "recall": 0.0,
-            "f1_score": 0.0,
-            "hit_rate": 0.0,
-            "mrr": 0.0
-        }
-        mock_evaluation_service._compute_retrieval_metrics.return_value = expected_metrics
-        
-        metrics = mock_evaluation_service._compute_retrieval_metrics(retrieved_ids, relevant_ids)
-        
-        assert metrics["precision"] == 0.0
-        assert metrics["recall"] == 0.0
-        assert metrics["hit_rate"] == 0.0
-    
-    def test_compute_summary_metrics(self, mock_evaluation_service):
-        """Test summary metrics computation"""
-        results = [
-            {"metrics": {"precision": 0.9, "recall": 0.8}, "execution_time": 1.2},
-            {"metrics": {"precision": 0.8, "recall": 0.7}, "execution_time": 1.5},
-            {"metrics": {"precision": 0.85, "recall": 0.75}, "execution_time": 1.3}
-        ]
-        
-        expected_summary = {
-            "total_cases": 3,
-            "avg_execution_time": 1.33,
-            "avg_precision": 0.85,
-            "avg_recall": 0.75
-        }
-        mock_evaluation_service._compute_summary_metrics.return_value = expected_summary
-        
-        summary = mock_evaluation_service._compute_summary_metrics(results)
-        
-        assert summary["total_cases"] == 3
-        assert summary["avg_precision"] > 0.8
-
-
-class TestEvaluationRecommendations:
-    """Tests for configuration recommendations"""
-    
-    @pytest.fixture
-    def mock_evaluation_service(self):
-        """Create a mock EvaluationService"""
-        with patch('api.db.services.evaluation_service.EvaluationService') as mock:
-            yield mock
-    
-    def test_get_recommendations_low_precision(self, mock_evaluation_service):
-        """Test recommendations for low precision"""
-        recommendations = [
-            {
-                "issue": "Low Precision",
-                "severity": "high",
-                "suggestions": [
-                    "Increase similarity_threshold",
-                    "Enable reranking"
-                ]
-            }
-        ]
-        mock_evaluation_service.get_recommendations.return_value = recommendations
-        
-        recs = mock_evaluation_service.get_recommendations("run_123")
-        
-        assert len(recs) > 0
-        assert any("precision" in r["issue"].lower() for r in recs)
-    
-    def test_get_recommendations_low_recall(self, mock_evaluation_service):
-        """Test recommendations for low recall"""
-        recommendations = [
-            {
-                "issue": "Low Recall",
-                "severity": "high",
-                "suggestions": [
-                    "Increase top_k",
-                    "Lower similarity_threshold"
-                ]
-            }
-        ]
-        mock_evaluation_service.get_recommendations.return_value = recommendations
-        
-        recs = mock_evaluation_service.get_recommendations("run_123")
-        
-        assert len(recs) > 0
-        assert any("recall" in r["issue"].lower() for r in recs)
-    
-    def test_get_recommendations_slow_response(self, mock_evaluation_service):
-        """Test recommendations for slow response time"""
-        recommendations = [
-            {
-                "issue": "Slow Response Time",
-                "severity": "medium",
-                "suggestions": [
-                    "Reduce top_k",
-                    "Optimize embedding model"
-                ]
-            }
-        ]
-        mock_evaluation_service.get_recommendations.return_value = recommendations
-        
-        recs = mock_evaluation_service.get_recommendations("run_123")
-        
-        assert len(recs) > 0
-        assert any("response" in r["issue"].lower() or "slow" in r["issue"].lower() for r in recs)
-    
-    def test_get_recommendations_no_issues(self, mock_evaluation_service):
-        """Test recommendations when metrics are good"""
-        mock_evaluation_service.get_recommendations.return_value = []
-        
-        recs = mock_evaluation_service.get_recommendations("run_123")
-        
-        assert len(recs) == 0
-
-
-if __name__ == "__main__":
-    pytest.main([__file__, "-v"])
--- a/uv.lock
+++ b/uv.lock
@@ -445,25 +445,25 @@ wheels = [

 [[package]]
 name = "bce-python-sdk"
-version = "0.9.54"
+version = "0.9.55"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "future" },
    { name = "pycryptodome" },
    { name = "six" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b3/c8/1c3bc30aa745ad4c3d073f150bddaf1d43ee6ee33f0b8ec60068494f511e/bce_python_sdk-0.9.54.tar.gz", hash = "sha256:f68026f40f11ea38ef445f50a7756009d5b703c7253438b138b30fb3b83be275", size = 275698, upload-time = "2025-11-27T02:28:50.24Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ff/ae/f31ee3ccae94e1a07d8886a413f08c1581349e6cb45bf8b3c608fbf173e4/bce_python_sdk-0.9.55.tar.gz", hash = "sha256:bed63f8a0975f2e9daecf53417c3d5b803232ad87f35a0b16e25850710ce209c", size = 275733, upload-time = "2025-12-02T12:02:38.041Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/69/a7/b8806c8505bb830cc863837ef8b42695170dd9561605c61262250df066d3/bce_python_sdk-0.9.54-py3-none-any.whl", hash = "sha256:a084eee577931f15a55280a7401bea2474115989ee79ebbca131610bdce81c99", size = 390447, upload-time = "2025-11-27T02:28:48.603Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/8f/01/1b13a627e5f0239f24b168138d9a948e876d4b387c03f59d31699578c960/bce_python_sdk-0.9.55-py3-none-any.whl", hash = "sha256:6045d19d783b548644cce50a2f41ef5242da6654fb91b2c21629f309ca6dbf4c", size = 390463, upload-time = "2025-12-02T12:02:36.417Z" },
 ]

 [[package]]
 name = "beartype"
-version = "0.22.7"
+version = "0.22.8"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/2c/49/e28a77f8a3868b1c9ff6a030678e84de24c4783bae4c12cec9443cf8fb54/beartype-0.22.7.tar.gz", hash = "sha256:c7269855b71e32b7c9f0fc662baade752eb525107266e053338c2f6e8873826b", size = 1599627, upload-time = "2025-11-29T06:49:56.751Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/8c/1d/794ae2acaa67c8b216d91d5919da2606c2bb14086849ffde7f5555f3a3a5/beartype-0.22.8.tar.gz", hash = "sha256:b19b21c9359722ee3f7cc433f063b3e13997b27ae8226551ea5062e621f61165", size = 1602262, upload-time = "2025-12-03T05:11:10.766Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/f6/0c/a764253610513295b7f57904b91fae1d99c7afd1b16b6eaae06fdfb71fb5/beartype-0.22.7-py3-none-any.whl", hash = "sha256:e13430ac07c61fa4bc54d375970438aeb9aa47a482c529a6f438ce52e18e6f50", size = 1330771, upload-time = "2025-11-29T06:49:54.545Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/14/2a/fbcbf5a025d3e71ddafad7efd43e34ec4362f4d523c3c471b457148fb211/beartype-0.22.8-py3-none-any.whl", hash = "sha256:b832882d04e41a4097bab9f63e6992bc6de58c414ee84cba9b45b67314f5ab2e", size = 1331895, upload-time = "2025-12-03T05:11:08.373Z" },
 ]

 [[package]]
@@ -1910,11 +1910,11 @@ wheels = [

 [[package]]
 name = "fsspec"
-version = "2025.10.0"
+version = "2025.12.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/24/7f/2747c0d332b9acfa75dc84447a066fdf812b5a6b8d30472b74d309bfe8cb/fsspec-2025.10.0.tar.gz", hash = "sha256:b6789427626f068f9a83ca4e8a3cc050850b6c0f71f99ddb4f542b8266a26a59", size = 309285, upload-time = "2025-10-30T14:58:44.036Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b6/27/954057b0d1f53f086f681755207dda6de6c660ce133c829158e8e8fe7895/fsspec-2025.12.0.tar.gz", hash = "sha256:c505de011584597b1060ff778bb664c1bc022e87921b0e4f10cc9c44f9635973", size = 309748, upload-time = "2025-12-03T15:23:42.687Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/eb/02/a6b21098b1d5d6249b7c5ab69dde30108a71e4e819d4a9778f1de1d5b70d/fsspec-2025.10.0-py3-none-any.whl", hash = "sha256:7c7712353ae7d875407f97715f0e1ffcc21e33d5b24556cb1e090ae9409ec61d", size = 200966, upload-time = "2025-10-30T14:58:42.53Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/51/c7/b64cae5dba3a1b138d7123ec36bb5ccd39d39939f18454407e5468f4763f/fsspec-2025.12.0-py3-none-any.whl", hash = "sha256:8bf1fe301b7d8acfa6e8571e3b1c3d158f909666642431cc78a1b7b4dbc5ec5b", size = 201422, upload-time = "2025-12-03T15:23:41.434Z" },
 ]

 [[package]]
@@ -2022,16 +2022,21 @@ wheels = [

 [[package]]
 name = "google-auth"
-version = "2.41.1"
+version = "2.43.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "cachetools" },
    { name = "pyasn1-modules" },
    { name = "rsa" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a8/af/5129ce5b2f9688d2fa49b463e544972a7c82b0fdb50980dafee92e121d9f/google_auth-2.41.1.tar.gz", hash = "sha256:b76b7b1f9e61f0cb7e88870d14f6a94aeef248959ef6992670efee37709cbfd2", size = 292284, upload-time = "2025-09-30T22:51:26.363Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ff/ef/66d14cf0e01b08d2d51ffc3c20410c4e134a1548fc246a6081eae585a4fe/google_auth-2.43.0.tar.gz", hash = "sha256:88228eee5fc21b62a1b5fe773ca15e67778cb07dc8363adcb4a8827b52d81483", size = 296359, upload-time = "2025-11-06T00:13:36.587Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/be/a4/7319a2a8add4cc352be9e3efeff5e2aacee917c85ca2fa1647e29089983c/google_auth-2.41.1-py2.py3-none-any.whl", hash = "sha256:754843be95575b9a19c604a848a41be03f7f2afd8c019f716dc1f51ee41c639d", size = 221302, upload-time = "2025-09-30T22:51:24.212Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/6f/d1/385110a9ae86d91cc14c5282c61fe9f4dc41c0b9f7d423c6ad77038c4448/google_auth-2.43.0-py2.py3-none-any.whl", hash = "sha256:af628ba6fa493f75c7e9dbe9373d148ca9f4399b5ea29976519e0a3848eddd16", size = 223114, upload-time = "2025-11-06T00:13:35.209Z" },
+]
+
+[package.optional-dependencies]
+requests = [
+    { name = "requests" },
 ]

 [[package]]
@@ -2049,15 +2054,15 @@ wheels = [

 [[package]]
 name = "google-auth-oauthlib"
-version = "1.2.3"
+version = "1.2.2"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "google-auth" },
    { name = "requests-oauthlib" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/86/a6/c6336a6ceb682709a4aa39e2e6b5754a458075ca92359512b6cbfcb25ae3/google_auth_oauthlib-1.2.3.tar.gz", hash = "sha256:eb09e450d3cc789ecbc2b3529cb94a713673fd5f7a22c718ad91cf75aedc2ea4", size = 21265, upload-time = "2025-10-30T21:28:19.105Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/fb/87/e10bf24f7bcffc1421b84d6f9c3377c30ec305d082cd737ddaa6d8f77f7c/google_auth_oauthlib-1.2.2.tar.gz", hash = "sha256:11046fb8d3348b296302dd939ace8af0a724042e8029c1b872d87fabc9f41684", size = 20955, upload-time = "2025-04-22T16:40:29.172Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/38/07/a54c100da461ffc5968457823fcc665a48fb4b875c68bcfecbfe24a10dbe/google_auth_oauthlib-1.2.3-py3-none-any.whl", hash = "sha256:7c0940e037677f25e71999607493640d071212e7f3c15aa0febea4c47a5a0680", size = 19184, upload-time = "2025-10-30T21:28:17.88Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ac/84/40ee070be95771acd2f4418981edb834979424565c3eec3cd88b6aa09d24/google_auth_oauthlib-1.2.2-py3-none-any.whl", hash = "sha256:fd619506f4b3908b5df17b65f39ca8d66ea56986e5472eb5978fd8f3786f00a2", size = 19072, upload-time = "2025-04-22T16:40:28.174Z" },
 ]

 [[package]]
@@ -2177,11 +2182,11 @@ wheels = [

 [[package]]
 name = "google-genai"
-version = "1.52.0"
+version = "1.53.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "anyio" },
-    { name = "google-auth" },
+    { name = "google-auth", extra = ["requests"] },
    { name = "httpx" },
    { name = "pydantic" },
    { name = "requests" },
@@ -2189,9 +2194,9 @@ dependencies = [
    { name = "typing-extensions" },
    { name = "websockets" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/09/4e/0ad8585d05312074bb69711b2d81cfed69ce0ae441913d57bf169bed20a7/google_genai-1.52.0.tar.gz", hash = "sha256:a74e8a4b3025f23aa98d6a0f84783119012ca6c336fd68f73c5d2b11465d7fc5", size = 258743, upload-time = "2025-11-21T02:18:55.742Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/de/b3/36fbfde2e21e6d3bc67780b61da33632f495ab1be08076cf0a16af74098f/google_genai-1.53.0.tar.gz", hash = "sha256:938a26d22f3fd32c6eeeb4276ef204ef82884e63af9842ce3eac05ceb39cbd8d", size = 260102, upload-time = "2025-12-03T17:21:23.233Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ec/66/03f663e7bca7abe9ccfebe6cb3fe7da9a118fd723a5abb278d6117e7990e/google_genai-1.52.0-py3-none-any.whl", hash = "sha256:c8352b9f065ae14b9322b949c7debab8562982f03bf71d44130cd2b798c20743", size = 261219, upload-time = "2025-11-21T02:18:54.515Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/40/f2/97fefdd1ad1f3428321bac819ae7a83ccc59f6439616054736b7819fa56c/google_genai-1.53.0-py3-none-any.whl", hash = "sha256:65a3f99e5c03c372d872cda7419f5940e723374bb12a2f3ffd5e3e56e8eb2094", size = 262015, upload-time = "2025-12-03T17:21:21.934Z" },
 ]

 [[package]]
@@ -2776,7 +2781,7 @@ wheels = [

 [[package]]
 name = "infinity-sdk"
-version = "0.6.8"
+version = "0.6.10"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "datrie" },
@@ -2795,9 +2800,9 @@ dependencies = [
    { name = "sqlglot", extra = ["rs"] },
    { name = "thrift" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a3/2d/4b699d62202319e5cbbcb4a7d9e87a86dde7ba7c767d0af4ebbee3de8419/infinity_sdk-0.6.8.tar.gz", hash = "sha256:e91c1f6cdf2fa41bc615c72be2a9e981211bd05b34522c1d27f1b825b905b125", size = 72669, upload-time = "2025-12-02T05:09:29.377Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b4/e5/88fdcfe42835c5494a08f02b64762a98e04dae4ad49f7dfabac18ee01928/infinity_sdk-0.6.10.tar.gz", hash = "sha256:b55c296ca3b2c8c2f4568f359dd8a50772e9432f09b64667140e9804bf780436", size = 29502969, upload-time = "2025-12-04T02:42:17.882Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ab/08/59ed1261ee80d3b2c5a80313a013a94cae83ce90ff1da1ef488055944a7b/infinity_sdk-0.6.8-py3-none-any.whl", hash = "sha256:392f942a2073a5b545261dad9859b217c6a0331ede606c8894e7ae335f2ead5e", size = 81564, upload-time = "2025-12-02T05:09:27.784Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/97/99/8857ea0805bd83fe092f5dca914a31f9fcc731c3800264657bd3ba950a1d/infinity_sdk-0.6.10-py3-none-any.whl", hash = "sha256:8f605039ec73d1b05d219105fbabef186e0178fddbad058c2c06c4873be48651", size = 29722107, upload-time = "2025-12-04T02:42:04.101Z" },
 ]

 [[package]]
@@ -3077,7 +3082,7 @@ wheels = [

 [[package]]
 name = "langfuse"
-version = "3.10.3"
+version = "3.10.5"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "backoff" },
@@ -3091,9 +3096,9 @@ dependencies = [
    { name = "requests" },
    { name = "wrapt" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/7b/03/c4316cb0a91cff97118c21b973b3089c2fe1bdbcad02f3623d6ac572e954/langfuse-3.10.3.tar.gz", hash = "sha256:69d6eaf573212f8cdc1cebd2d6b47f271bfe76c7eb5a3c5d6766bb0d9bf0004c", size = 226617, upload-time = "2025-12-01T18:01:02.607Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/69/21/dff0434290512484436bfa108e36f0adc3457eb4117767de70e76a411cac/langfuse-3.10.5.tar.gz", hash = "sha256:14eb767663f7e7480cd1cd1b3ca457022817c129e666efe97e5c80adb8c5aac0", size = 223142, upload-time = "2025-12-03T17:49:39.747Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/fd/04/f07c2a23f2822f73f8576b1ba7348c014c4be65127384b4bee475f913f3b/langfuse-3.10.3-py3-none-any.whl", hash = "sha256:b9a2e6506f8f0923c2f4b8c9e3fa355231994197a17f75509a37f335660ce334", size = 399062, upload-time = "2025-12-01T18:01:00.688Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/64/6f/dc15775f82d38da62cd2015110f5802bb175a9ee731a4533fe2a0cdf75b6/langfuse-3.10.5-py3-none-any.whl", hash = "sha256:0223a64109a4293b9bd9b2e0e3229f53b75291cd96341e42cc3eba186973fcdb", size = 398888, upload-time = "2025-12-03T17:49:38.171Z" },
 ]

 [[package]]
@@ -4043,32 +4048,32 @@ wheels = [

 [[package]]
 name = "opentelemetry-api"
-version = "1.38.0"
+version = "1.39.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "importlib-metadata" },
    { name = "typing-extensions" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/08/d8/0f354c375628e048bd0570645b310797299754730079853095bf000fba69/opentelemetry_api-1.38.0.tar.gz", hash = "sha256:f4c193b5e8acb0912b06ac5b16321908dd0843d75049c091487322284a3eea12", size = 65242, upload-time = "2025-10-16T08:35:50.25Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/c0/0b/e5428c009d4d9af0515b0a8371a8aaae695371af291f45e702f7969dce6b/opentelemetry_api-1.39.0.tar.gz", hash = "sha256:6130644268c5ac6bdffaf660ce878f10906b3e789f7e2daa5e169b047a2933b9", size = 65763, upload-time = "2025-12-03T13:19:56.378Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ae/a2/d86e01c28300bd41bab8f18afd613676e2bd63515417b77636fc1add426f/opentelemetry_api-1.38.0-py3-none-any.whl", hash = "sha256:2891b0197f47124454ab9f0cf58f3be33faca394457ac3e09daba13ff50aa582", size = 65947, upload-time = "2025-10-16T08:35:30.23Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/05/85/d831a9bc0a9e0e1a304ff3d12c1489a5fbc9bf6690a15dcbdae372bbca45/opentelemetry_api-1.39.0-py3-none-any.whl", hash = "sha256:3c3b3ca5c5687b1b5b37e5c5027ff68eacea8675241b29f13110a8ffbb8f0459", size = 66357, upload-time = "2025-12-03T13:19:33.043Z" },
 ]

 [[package]]
 name = "opentelemetry-exporter-otlp-proto-common"
-version = "1.38.0"
+version = "1.39.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "opentelemetry-proto" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/19/83/dd4660f2956ff88ed071e9e0e36e830df14b8c5dc06722dbde1841accbe8/opentelemetry_exporter_otlp_proto_common-1.38.0.tar.gz", hash = "sha256:e333278afab4695aa8114eeb7bf4e44e65c6607d54968271a249c180b2cb605c", size = 20431, upload-time = "2025-10-16T08:35:53.285Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/11/cb/3a29ce606b10c76d413d6edd42d25a654af03e73e50696611e757d2602f3/opentelemetry_exporter_otlp_proto_common-1.39.0.tar.gz", hash = "sha256:a135fceed1a6d767f75be65bd2845da344dd8b9258eeed6bc48509d02b184409", size = 20407, upload-time = "2025-12-03T13:19:59.003Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a7/9e/55a41c9601191e8cd8eb626b54ee6827b9c9d4a46d736f32abc80d8039fc/opentelemetry_exporter_otlp_proto_common-1.38.0-py3-none-any.whl", hash = "sha256:03cb76ab213300fe4f4c62b7d8f17d97fcfd21b89f0b5ce38ea156327ddda74a", size = 18359, upload-time = "2025-10-16T08:35:34.099Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ef/c6/215edba62d13a3948c718b289539f70e40965bc37fc82ecd55bb0b749c1a/opentelemetry_exporter_otlp_proto_common-1.39.0-py3-none-any.whl", hash = "sha256:3d77be7c4bdf90f1a76666c934368b8abed730b5c6f0547a2ec57feb115849ac", size = 18367, upload-time = "2025-12-03T13:19:36.906Z" },
 ]

 [[package]]
 name = "opentelemetry-exporter-otlp-proto-http"
-version = "1.38.0"
+version = "1.39.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "googleapis-common-protos" },
@@ -4079,48 +4084,48 @@ dependencies = [
    { name = "requests" },
    { name = "typing-extensions" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/81/0a/debcdfb029fbd1ccd1563f7c287b89a6f7bef3b2902ade56797bfd020854/opentelemetry_exporter_otlp_proto_http-1.38.0.tar.gz", hash = "sha256:f16bd44baf15cbe07633c5112ffc68229d0edbeac7b37610be0b2def4e21e90b", size = 17282, upload-time = "2025-10-16T08:35:54.422Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/81/dc/1e9bf3f6a28e29eba516bc0266e052996d02bc7e92675f3cd38169607609/opentelemetry_exporter_otlp_proto_http-1.39.0.tar.gz", hash = "sha256:28d78fc0eb82d5a71ae552263d5012fa3ebad18dfd189bf8d8095ba0e65ee1ed", size = 17287, upload-time = "2025-12-03T13:20:01.134Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/e5/77/154004c99fb9f291f74aa0822a2f5bbf565a72d8126b3a1b63ed8e5f83c7/opentelemetry_exporter_otlp_proto_http-1.38.0-py3-none-any.whl", hash = "sha256:84b937305edfc563f08ec69b9cb2298be8188371217e867c1854d77198d0825b", size = 19579, upload-time = "2025-10-16T08:35:36.269Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/bc/46/e4a102e17205bb05a50dbf24ef0e92b66b648cd67db9a68865af06a242fd/opentelemetry_exporter_otlp_proto_http-1.39.0-py3-none-any.whl", hash = "sha256:5789cb1375a8b82653328c0ce13a054d285f774099faf9d068032a49de4c7862", size = 19639, upload-time = "2025-12-03T13:19:39.536Z" },
 ]

 [[package]]
 name = "opentelemetry-proto"
-version = "1.38.0"
+version = "1.39.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "protobuf" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/51/14/f0c4f0f6371b9cb7f9fa9ee8918bfd59ac7040c7791f1e6da32a1839780d/opentelemetry_proto-1.38.0.tar.gz", hash = "sha256:88b161e89d9d372ce723da289b7da74c3a8354a8e5359992be813942969ed468", size = 46152, upload-time = "2025-10-16T08:36:01.612Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/48/b5/64d2f8c3393cd13ea2092106118f7b98461ba09333d40179a31444c6f176/opentelemetry_proto-1.39.0.tar.gz", hash = "sha256:c1fa48678ad1a1624258698e59be73f990b7fc1f39e73e16a9d08eef65dd838c", size = 46153, upload-time = "2025-12-03T13:20:08.729Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b6/6a/82b68b14efca5150b2632f3692d627afa76b77378c4999f2648979409528/opentelemetry_proto-1.38.0-py3-none-any.whl", hash = "sha256:b6ebe54d3217c42e45462e2a1ae28c3e2bf2ec5a5645236a490f55f45f1a0a18", size = 72535, upload-time = "2025-10-16T08:35:45.749Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/e3/4d/d500e1862beed68318705732d1976c390f4a72ca8009c4983ff627acff20/opentelemetry_proto-1.39.0-py3-none-any.whl", hash = "sha256:1e086552ac79acb501485ff0ce75533f70f3382d43d0a30728eeee594f7bf818", size = 72534, upload-time = "2025-12-03T13:19:50.251Z" },
 ]

 [[package]]
 name = "opentelemetry-sdk"
-version = "1.38.0"
+version = "1.39.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "opentelemetry-api" },
    { name = "opentelemetry-semantic-conventions" },
    { name = "typing-extensions" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/85/cb/f0eee1445161faf4c9af3ba7b848cc22a50a3d3e2515051ad8628c35ff80/opentelemetry_sdk-1.38.0.tar.gz", hash = "sha256:93df5d4d871ed09cb4272305be4d996236eedb232253e3ab864c8620f051cebe", size = 171942, upload-time = "2025-10-16T08:36:02.257Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/51/e3/7cd989003e7cde72e0becfe830abff0df55c69d237ee7961a541e0167833/opentelemetry_sdk-1.39.0.tar.gz", hash = "sha256:c22204f12a0529e07aa4d985f1bca9d6b0e7b29fe7f03e923548ae52e0e15dde", size = 171322, upload-time = "2025-12-03T13:20:09.651Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/2f/2e/e93777a95d7d9c40d270a371392b6d6f1ff170c2a3cb32d6176741b5b723/opentelemetry_sdk-1.38.0-py3-none-any.whl", hash = "sha256:1c66af6564ecc1553d72d811a01df063ff097cdc82ce188da9951f93b8d10f6b", size = 132349, upload-time = "2025-10-16T08:35:46.995Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a4/b4/2adc8bc83eb1055ecb592708efb6f0c520cc2eb68970b02b0f6ecda149cf/opentelemetry_sdk-1.39.0-py3-none-any.whl", hash = "sha256:90cfb07600dfc0d2de26120cebc0c8f27e69bf77cd80ef96645232372709a514", size = 132413, upload-time = "2025-12-03T13:19:51.364Z" },
 ]

 [[package]]
 name = "opentelemetry-semantic-conventions"
-version = "0.59b0"
+version = "0.60b0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
 dependencies = [
    { name = "opentelemetry-api" },
    { name = "typing-extensions" },
 ]
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/40/bc/8b9ad3802cd8ac6583a4eb7de7e5d7db004e89cb7efe7008f9c8a537ee75/opentelemetry_semantic_conventions-0.59b0.tar.gz", hash = "sha256:7a6db3f30d70202d5bf9fa4b69bc866ca6a30437287de6c510fb594878aed6b0", size = 129861, upload-time = "2025-10-16T08:36:03.346Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/71/0e/176a7844fe4e3cb5de604212094dffaed4e18b32f1c56b5258bcbcba85c2/opentelemetry_semantic_conventions-0.60b0.tar.gz", hash = "sha256:227d7aa73cbb8a2e418029d6b6465553aa01cf7e78ec9d0bc3255c7b3ac5bf8f", size = 137935, upload-time = "2025-12-03T13:20:12.395Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/24/7d/c88d7b15ba8fe5c6b8f93be50fc11795e9fc05386c44afaf6b76fe191f9b/opentelemetry_semantic_conventions-0.59b0-py3-none-any.whl", hash = "sha256:35d3b8833ef97d614136e253c1da9342b4c3c083bbaf29ce31d572a1c3825eed", size = 207954, upload-time = "2025-10-16T08:35:48.054Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/d0/56/af0306666f91bae47db14d620775604688361f0f76a872e0005277311131/opentelemetry_semantic_conventions-0.60b0-py3-none-any.whl", hash = "sha256:069530852691136018087b52688857d97bba61cd641d0f8628d2d92788c4f78a", size = 219981, upload-time = "2025-12-03T13:19:53.585Z" },
 ]

 [[package]]
@@ -5683,7 +5688,7 @@ requires-dist = [
    { name = "huggingface-hub", specifier = ">=0.25.0,<0.26.0" },
    { name = "imageio-ffmpeg", specifier = ">=0.6.0" },
    { name = "infinity-emb", specifier = ">=0.0.66,<0.0.67" },
-    { name = "infinity-sdk", specifier = "==0.6.8" },
+    { name = "infinity-sdk", specifier = "==0.6.10" },
    { name = "itsdangerous", specifier = "==2.1.2" },
    { name = "jira", specifier = "==3.10.5" },
    { name = "json-repair", specifier = "==0.35.0" },
@@ -6712,11 +6717,11 @@ wheels = [

 [[package]]
 name = "sqlglot"
-version = "28.0.0"
+version = "28.1.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/52/8d/9ce5904aca760b81adf821c77a1dcf07c98f9caaa7e3b5c991c541ff89d2/sqlglot-28.0.0.tar.gz", hash = "sha256:cc9a651ef4182e61dac58aa955e5fb21845a5865c6a4d7d7b5a7857450285ad4", size = 5520798, upload-time = "2025-11-17T10:34:57.016Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/7e/49/cda1fc4e610ed5764de2842bb2f362f4aba267b4a7d05a3a217a25b39004/sqlglot-28.1.0.tar.gz", hash = "sha256:a3ef7344359667b51cf95e840aac70a49f847602c61c9fbaeb847f74f7877fe1", size = 5546281, upload-time = "2025-12-02T16:52:28.387Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/56/6d/86de134f40199105d2fee1b066741aa870b3ce75ee74018d9c8508bbb182/sqlglot-28.0.0-py3-none-any.whl", hash = "sha256:ac1778e7fa4812f4f7e5881b260632fc167b00ca4c1226868891fb15467122e4", size = 536127, upload-time = "2025-11-17T10:34:55.192Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/2c/e8/bd016214348f65ba31107c1b81af70fc7662d96758052d5d59b516fd3858/sqlglot-28.1.0-py3-none-any.whl", hash = "sha256:2a895a31666ba947c686caa980624c82bcd0e6fdf59b4fdb9e47108bd092d1ac", size = 547889, upload-time = "2025-12-02T16:52:26.019Z" },
 ]

 [package.optional-dependencies]
@@ -6726,40 +6731,40 @@ rs = [

 [[package]]
 name = "sqlglotrs"
-version = "0.7.3"
+version = "0.8.0"
 source = { registry = "https://pypi.tuna.tsinghua.edu.cn/simple" }
-sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/87/5a/46d8efeda45be6ce1c630229455f000cafedea6129b47e6cfab39ff462f5/sqlglotrs-0.7.3.tar.gz", hash = "sha256:caadc572c8a194f99d6ba44d02f9ada0110e3d47cca3330c81f4aa608f1143eb", size = 15888, upload-time = "2025-10-13T06:33:57.322Z" }
+sdist = { url = "https://pypi.tuna.tsinghua.edu.cn/packages/d5/37/118f24c367fde662e6c1181327dc9c16d08914108904c69bac3a6ba12c52/sqlglotrs-0.8.0.tar.gz", hash = "sha256:2b9a23c580d82be2388ee23496230cfc667f280ed0ed7eaa099d0da8d718cbf2", size = 15706, upload-time = "2025-12-02T16:58:38.197Z" }
 wheels = [
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/9d/95/f08e01f54e521a286fcd9f7a8bdd178eabcddd9dbc6d6c15dc983c7be8dd/sqlglotrs-0.7.3-cp310-cp310-macosx_10_12_x86_64.whl", hash = "sha256:7acc6dba37af53d9cf1e3217fdd719878dbfaaf2a578ad7b3fbc07ef9dadd035", size = 314621, upload-time = "2025-10-13T06:33:48.917Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/98/7d/01a5db15e413ab587816448f1222286d3a10f0465954d21f5d2915aaeed5/sqlglotrs-0.7.3-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:3cbfb42071422afbd7376d70b93a969e86fb74752efe98dd66ee6d2ae27a9665", size = 300189, upload-time = "2025-10-13T06:33:40.963Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/08/21/94d1fb647a394afcb09a9174f7bff078452bb956e6898093dd9ee459ef2b/sqlglotrs-0.7.3-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:07500421de9dea8dfc0cd6769145df754178fc2ae5a3692bdbf5d37aebc0712a", size = 332771, upload-time = "2025-10-13T06:32:45.992Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/29/d1/ccade8e794304c925e9b94e1d7bff4c56896f571a291a03bfd96048c4a0f/sqlglotrs-0.7.3-cp310-cp310-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:792eb179a742d7d72d1d47c9a50e073078f0133e9191bd07920945dcc9170844", size = 342960, upload-time = "2025-10-13T06:32:55.493Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/1e/2f/2ff3cfe7d91ac3762100e511c4eff0c98824970d7c27e18e88c44a4d4567/sqlglotrs-0.7.3-cp310-cp310-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:f4c3849992e33e47403c2517d464564e4b4cf6a080ad761141504e271ab2c7cd", size = 487268, upload-time = "2025-10-13T06:33:13.784Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/3f/d7/a95fbdd26f20b7bd5781bb5a4c51616fdd59f1c521010f668ffd54e59f5d/sqlglotrs-0.7.3-cp310-cp310-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:016f51409ed3d87c33ca5a31dd6766e75a809909e418a0ffd2965e0ae7b84a7b", size = 365853, upload-time = "2025-10-13T06:33:23.415Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/53/7a/5d50d0b1167c79a509957d58a6bf9f6450f894e0bc233987cb85ccaec50f/sqlglotrs-0.7.3-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:94dd711ea2ba76e664dab3e7f7b08cb5517cf5164fd94a552598acfd1f6df59a", size = 343697, upload-time = "2025-10-13T06:33:32.542Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/e5/89/85acbd412a5c7ef39ee5a96f5be28d6d38bce2c4521a264c747361b4c021/sqlglotrs-0.7.3-cp310-cp310-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:517198977f3baece667513326e42545b00b2878719922c58fcbfa21553f1338d", size = 363446, upload-time = "2025-10-13T06:33:03.995Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/37/4d/0a04f29731b6fda327bd11495c143ce70d1a7446b22440a32d8571408a06/sqlglotrs-0.7.3-cp310-cp310-win32.whl", hash = "sha256:1e9121ef3a64dc7d18e500e5e93df458a9bb6f4111b8f8569d5e4f8db21e61d2", size = 183997, upload-time = "2025-10-13T06:33:58.579Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/0e/16/0e95fa77409da059c951c6be11d4d73311c60bb5ed82f1d40a4afc9a1aa9/sqlglotrs-0.7.3-cp310-cp310-win_amd64.whl", hash = "sha256:48fd7e9efef56331e1ef7402b6d65113c087da1cfe2ef80d143ee62046d49056", size = 195923, upload-time = "2025-10-13T06:34:06.676Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/82/41/fcd87de298b562947cb2592feb9df5794886a8fa24eab8a080a552aa0e4d/sqlglotrs-0.7.3-cp311-cp311-macosx_10_12_x86_64.whl", hash = "sha256:f2144fc8e472de2b165665c1370e7f0ca7f9400f60ca5e78c7aedbb3233bc8d7", size = 314465, upload-time = "2025-10-13T06:33:50.219Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/14/81/22cf241e22f364c414d57893fad9cfea869f8866189e75575a3862f1d329/sqlglotrs-0.7.3-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:93cb74928b205da3f29f2b9c728d2c6656ad30e1ef500560f6c851bca2129fbc", size = 300129, upload-time = "2025-10-13T06:33:42.205Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a5/90/4e4220f8605c6fbca77dfad2052cdebf195099c99fd0684723677dcbf091/sqlglotrs-0.7.3-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:a918137bacfa31529802063e349a99d5352f74c914beceb14689cd2864c5e4d0", size = 332735, upload-time = "2025-10-13T06:32:48.095Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/3b/35/abe3cb6aa197b5193fcb446ab69465b5927e09e281b2c05f4e12249fd335/sqlglotrs-0.7.3-cp311-cp311-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:c3fd0edbd957d136c67919ead10c90d832da1aedbbedc6da899d173fe78bf600", size = 342779, upload-time = "2025-10-13T06:32:56.782Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/22/71/670ad31f4dbfe594592a1992c4e7a62003dc47dffb15d96b2fec4137f933/sqlglotrs-0.7.3-cp311-cp311-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:5a361a1dd8c55fbc57f81db738658141cab723509cc1b3edcc871bccfbba0cfb", size = 487344, upload-time = "2025-10-13T06:33:15.095Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/f4/73/86e46b762b615c7cdec489e4b0670d2a04ea6fab0c0be30a5756e95f108f/sqlglotrs-0.7.3-cp311-cp311-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:c698af6379475c243a8f190845bf1d1267a2c9867011a4567d5cfdcc5b0eb094", size = 366062, upload-time = "2025-10-13T06:33:25.183Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/dc/07/b4dd7315df7d975c4b82d09106eb73ea2ee8f3734f764889913636e9d68c/sqlglotrs-0.7.3-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:75d63ed29058c56f153912c90811d8af1706d81f0c759883baeb21acb6322969", size = 343642, upload-time = "2025-10-13T06:33:33.826Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/37/84/2e834fc665236ef6b0fced14d75c8e9eb0db471d96fde539d8c37ce3a10f/sqlglotrs-0.7.3-cp311-cp311-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:4e19dee6dc46c4d84c556ae456fa0c6400edb157528fd369670b3d041b54ef21", size = 363731, upload-time = "2025-10-13T06:33:05.913Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ad/db/b7063b1240a1c39bc5627880dbb80c9e3f7b5548a17962d3a6bf98239171/sqlglotrs-0.7.3-cp311-cp311-win32.whl", hash = "sha256:f1276d0f02eaefbdd149b614f6c21fb9be372d7e1137f19c3d5f9e50662367b3", size = 183607, upload-time = "2025-10-13T06:33:59.858Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/09/98/e9cb2b3dd4abb34d2ae71747f113bf12f741a86fa29e661f1f09ba8376d0/sqlglotrs-0.7.3-cp311-cp311-win_amd64.whl", hash = "sha256:ccf05fc6e89523cf5819982fab12b8fe07a9656dbb5356fc4b56b562e734c202", size = 196050, upload-time = "2025-10-13T06:34:07.921Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/23/3f/3b059058e198b2fb6612d0ddaad5431a796d7081d40b21f12273ea1b26dc/sqlglotrs-0.7.3-cp312-cp312-macosx_10_12_x86_64.whl", hash = "sha256:2e7be55bf719b5ebdc344a996b6d27b9a0ba9bae0a09462900805e2f7dc4dca5", size = 310987, upload-time = "2025-10-13T06:33:51.874Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/47/b6/0058b2fe4f4813d9f3280d65ace97a637e8edd152be2a13bb1782c5c2eff/sqlglotrs-0.7.3-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:6fef415993e1843201a57916f310b49e79669db379ff38094161fa93be2ffdf2", size = 296829, upload-time = "2025-10-13T06:33:43.838Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/f3/a8/35c593b03bf498876aea68ea944a7e7bb9cf648e68984f55795181c928dd/sqlglotrs-0.7.3-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:e980354e576e852c53e0bb5444b04ebb6459054074bce8012cc3385dd3d116ed", size = 332313, upload-time = "2025-10-13T06:32:49.343Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/e9/bc/534e21a233846d33d6b55100485bf1844d301b0b75deded5310ef9cd171f/sqlglotrs-0.7.3-cp312-cp312-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:1444b260c040cc80697956629f3fd3adece0bdb4f83bae22cd618ca3f18c4de8", size = 342309, upload-time = "2025-10-13T06:32:58.031Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/71/63/1d7bd7de87f01adb43cd1710d3fd5b9d5b0b3fea160bbeadc340fe1a9132/sqlglotrs-0.7.3-cp312-cp312-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:3202c6f00145b8adb4632c1bb5071be5aa362829054653bac058dbcdbc6228e7", size = 484954, upload-time = "2025-10-13T06:33:16.697Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/6f/bd/10126c9f59fb4f8fa51bf3f0ad17895b953bd09e1687986d5d9e110758c8/sqlglotrs-0.7.3-cp312-cp312-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:17ae27e895f0ed960e28e76028c84758ff00df24e598654df3b5f22de8c7fc30", size = 366874, upload-time = "2025-10-13T06:33:26.888Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a3/fa/f12a1eb9c22cdce962bafebefea58e898c19bae3d21e9b79d6e811a2951d/sqlglotrs-0.7.3-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:9a36c3d55b913c09dc31572ca7d5b423e85d761f1b3c9d8f86e2a1433a2f20d5", size = 342990, upload-time = "2025-10-13T06:33:35.478Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/86/1d/2bd1c8900d7a081a61a1c424785fd1a1452def751bc212630251423d80ce/sqlglotrs-0.7.3-cp312-cp312-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:94875611a2a953c06e8152b1d485f4d20ec61b72ebd848f96c04aca66b30f189", size = 362603, upload-time = "2025-10-13T06:33:07.507Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/18/3a/9c176a7f9b93d78168b3d137db4704a703cb51b32edb29d231b615130b47/sqlglotrs-0.7.3-cp312-cp312-win32.whl", hash = "sha256:64a708c87d1bea1f4bdb3edf0a3e94ea1b908ed229502da93621a4a50ef20189", size = 183180, upload-time = "2025-10-13T06:34:01.017Z" },
-    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/df/ea/37757060d3caadb22509d349087e1e16a2dcc4c1649a00d2d6b501f8ff50/sqlglotrs-0.7.3-cp312-cp312-win_amd64.whl", hash = "sha256:fe1ef1bedbb34b87dfb4e99a911026f8895ff2514b222cfd82cd08033406de2e", size = 195746, upload-time = "2025-10-13T06:34:09.478Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/d7/88/7fc59c146118603e06abf69dc19c237ef496a8dd936e5c224fdffc7df120/sqlglotrs-0.8.0-cp310-cp310-macosx_10_12_x86_64.whl", hash = "sha256:3db8f75b8efe5b94ed5540c13b80ef0a3e64c0d15864b05a6bccf5554c6e6008", size = 318097, upload-time = "2025-12-02T16:58:30.763Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/44/9a/7c0103f02b371f49f6ade420519d54c11c7e3ae4dcf22a855b9c71ccb546/sqlglotrs-0.8.0-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:37d00b69814fdabd4256be955d66e699afa1c50740f03369503d85f90245af35", size = 306820, upload-time = "2025-12-02T16:58:23.714Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/4a/cf/52de2a02a52976dfbd863ec57a3fafaf018a9536114f195404d51717501d/sqlglotrs-0.8.0-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:631da494550442ec2c7139993f59d854e4d4a44282b568594b5fc50818bc4736", size = 341540, upload-time = "2025-12-02T16:57:33.009Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b8/89/072a295c3b98322a3d08d85ed47551c1f080309f2cde2d2fa75bd1964621/sqlglotrs-0.8.0-cp310-cp310-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:6b624e0650067cc006d8a0595e07be3ac91599187ee353313eb9f114ca434e44", size = 350048, upload-time = "2025-12-02T16:57:41.477Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/fd/b2/fbc05eef045124a9e5820812ddd641ec42add5e52f12126a85d942b0f166/sqlglotrs-0.8.0-cp310-cp310-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:6c0c5ae335b1917aa101d7cfe1aacbedf3b54f489d2038e94c8f42ffe5bd304a", size = 474032, upload-time = "2025-12-02T16:58:00.344Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b2/a8/1472a5d5f849803fb2ad566ae43db8e5c9f3b1686b104dda245e4acfd963/sqlglotrs-0.8.0-cp310-cp310-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:21d145e9fef6e2e53fdf17f9b6ab7e7fbba26064365c56d2103a41e95053d1d4", size = 365233, upload-time = "2025-12-02T16:58:08.102Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/ab/c8/ea700f277cba380c7919136a16e03f9f990f29da34c5404b861fbb8b6fd5/sqlglotrs-0.8.0-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:9ed5d7afd8b6b244c33316cc292122f26c20bf9677907bc5790c1b053097aff4", size = 348452, upload-time = "2025-12-02T16:58:15.863Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/60/f7/ba63c7cabcd71abed855e7a4cecb4b0df297bf17d315ff39eacf94926378/sqlglotrs-0.8.0-cp310-cp310-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:185442ad85a125719bf365a238c2b357c079cb5a13392adbbde172b1a0073410", size = 371656, upload-time = "2025-12-02T16:57:51.329Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/5c/dc/1ba05670afe7f4c7e651f972f4738dc4508525bb67b9151cdf463b0ef55b/sqlglotrs-0.8.0-cp310-cp310-win32.whl", hash = "sha256:a7d3f36d9c53090842ae18de6d96bd7634d73584255014983aad998f2b7dc95f", size = 188554, upload-time = "2025-12-02T16:58:39.078Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/33/fc/a393a837a9e09411da87cf8ee2d9f190e3bad37d289cd385e3791356a788/sqlglotrs-0.8.0-cp310-cp310-win_amd64.whl", hash = "sha256:c8a5e3c8870323666e9695be7cc65f710ed437ceea572e69e2b14e63b70f21b2", size = 200973, upload-time = "2025-12-02T16:58:46.02Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/3d/be/a6a8e41e59813663baf02b23534d822b62521d018ee740f132b4547c4239/sqlglotrs-0.8.0-cp311-cp311-macosx_10_12_x86_64.whl", hash = "sha256:0267b0121073669d1184bc0441779559e6b0c6067a12571b63befa2a9b4b0f77", size = 318016, upload-time = "2025-12-02T16:58:32.555Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/08/02/bf65a608b2caf268d81073171196f93beed8d32731ebda1288153dec2b73/sqlglotrs-0.8.0-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:30c1a2fa22a3ae4b38c7df9abbf14b2473f7e71c859c95bc270bd4a169688380", size = 306527, upload-time = "2025-12-02T16:58:24.853Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/39/98/32de2ad5ea9310e220baabfb6b2ee1e3c7ebb3b83a1db9bd2acdf72de6a5/sqlglotrs-0.8.0-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:e7df3d2117c92004aa20082d71fbbd1735f063f123354d32d0b2b602ab4e1353", size = 341821, upload-time = "2025-12-02T16:57:34.854Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/3b/99/64247cb3b9f99ca09aafa11791fe250326d498b194795af91cc957003852/sqlglotrs-0.8.0-cp311-cp311-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:ecd7fdfd1be44828a8a8046ee743ffbaf93a972d7a125ff13e4673bb659fcf2c", size = 350003, upload-time = "2025-12-02T16:57:42.659Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/d0/91/bc15e4d2322cc28f4f94e519b2ae927ba42844830efaacf973ff774d8e06/sqlglotrs-0.8.0-cp311-cp311-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:171df6454f3dc064b89895c51cfb713163188493b36b845bf7c17df0e5702095", size = 474163, upload-time = "2025-12-02T16:58:01.554Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/93/8e/736451fc39f68f1e394a90d768dd9c8135412669ea3460e47033308cbb2e/sqlglotrs-0.8.0-cp311-cp311-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:497472ed07445a693e2699fd6f1b8ed5b8320488ade6a4a8e476664ee93ea51c", size = 365088, upload-time = "2025-12-02T16:58:09.604Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/97/2c/214f352fe03652b08873dcb8f4e6799a02be71446bdf9fea99ce13a502f3/sqlglotrs-0.8.0-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:b2be9add4daed501e28564208b30d4a772dfd6aaa1ad10dadd2d49f4e851f9fa", size = 348368, upload-time = "2025-12-02T16:58:17.363Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/e6/22/c445428a52d053a6f6b31858ac817afb997316e9f0ab2ee3187a10bd85a4/sqlglotrs-0.8.0-cp311-cp311-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:871d5ee6414f2d7116b670d0430c16f5b3d5a96480c274f7f3d50d97dbea7601", size = 371720, upload-time = "2025-12-02T16:57:52.71Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/20/b2/301261db4ac543891f897b58a036e87ff33158ea4eda050ee0e08ae0083a/sqlglotrs-0.8.0-cp311-cp311-win32.whl", hash = "sha256:1bbe94effd9d64a8bdca12e0f14b28388059cb5a381561bac07aafedc8c63761", size = 188284, upload-time = "2025-12-02T16:58:40.21Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/c8/a1/0534075d3b8a7c8ab8eff4ea7ba0338a2ef76e3d2e49105b189049430e99/sqlglotrs-0.8.0-cp311-cp311-win_amd64.whl", hash = "sha256:05a5098ec2836799c4c43b06df7c68a2b4c19c0fce042a66706fe3edc957459d", size = 201117, upload-time = "2025-12-02T16:58:47.14Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/fd/20/7beddfd545aaebbfee10a77ac8ef8a205ff597f9ce041c4b0437d0194392/sqlglotrs-0.8.0-cp312-cp312-macosx_10_12_x86_64.whl", hash = "sha256:fcb53f27cf4b9cae8a66c5777b84eeb3d079e96bcb4277b627fd90bfd1a591b5", size = 314699, upload-time = "2025-12-02T16:58:33.82Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/47/6f/6223a1946fe24a979b8af3c7ae2d16c5451d8f35f2468782bd4af2c122da/sqlglotrs-0.8.0-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:4da1480cc288e02bd459e4638f212fa86a1fef81eb2cd69e6fdbdeb64e3df729", size = 303385, upload-time = "2025-12-02T16:58:26.052Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/a0/98/55050208ef839cad740df6ca86f2f3ca895d469f6ce2040cba32d0b6c4a0/sqlglotrs-0.8.0-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:dc4a77df178b0ba242aba0e7cd775c3f9aef0fa79dfc31c6e642431ce690f51f", size = 341580, upload-time = "2025-12-02T16:57:36.197Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/eb/f2/6f1d207e629fd4810cc826cf419acc386f3d43d32987684730fbc2399503/sqlglotrs-0.8.0-cp312-cp312-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:a8647d20cc5a9ff39071786169b3f1acf56f266483fa55386111783bca335f04", size = 348451, upload-time = "2025-12-02T16:57:43.756Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/df/1b/fa8a0907471fe7be3754bac683a21c984b17672eef6958206473f683b63a/sqlglotrs-0.8.0-cp312-cp312-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:1afdd6a0fa915b3aef7c801cbdc815bb39b3d6aecc4d5b04c4ce54d3f73d0013", size = 475703, upload-time = "2025-12-02T16:58:02.843Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/92/56/f020c9c48d68883f6e24d69d18fe386eafc5963bc3982cc45013ec9b1ba0/sqlglotrs-0.8.0-cp312-cp312-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:3b4c1edeb80f572cf3586b9a23d15f18f48ac8dc481eceabdbb85dc7dbf8a2ce", size = 365842, upload-time = "2025-12-02T16:58:10.847Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/61/7b/091464f8aa2232a2f33028f9c9a2cbea7c4e5719400656f203592d46264d/sqlglotrs-0.8.0-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:9b6d819f2753804d55b10e4320df08350cd2739556572a97ed1b1d7fc939f194", size = 348397, upload-time = "2025-12-02T16:58:18.567Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/b7/1b/1b0cf0d41e8412786d1e80695778db799520223acf85c3ddc53c1200731f/sqlglotrs-0.8.0-cp312-cp312-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:dcf2cce002969cefb1466f2837c716d20fc9eac62b05043523fda25b3de4c444", size = 369756, upload-time = "2025-12-02T16:57:53.85Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/31/6e/d9e50472aa92736751abf3d6fcad1c793f0701f17a553ae787e4a7581a1d/sqlglotrs-0.8.0-cp312-cp312-win32.whl", hash = "sha256:5459235a25b30eae508bcaea8bc6ebc04610acd87e985ba4d602981a94078384", size = 187891, upload-time = "2025-12-02T16:58:41.57Z" },
+    { url = "https://pypi.tuna.tsinghua.edu.cn/packages/3b/a2/21d09ff2065a7e883f8f68dcea57fb23f6f04ba7a193f2ac2895b5dfafae/sqlglotrs-0.8.0-cp312-cp312-win_amd64.whl", hash = "sha256:1e0de4fa8e6c54419bd63a1205f3218feb5e2649d72f1bc69c5261b6c333e63b", size = 200842, upload-time = "2025-12-02T16:58:48.181Z" },
 ]

 [[package]]
--- a/web/src/components/markdown-content/index.tsx
+++ b/web/src/components/markdown-content/index.tsx
@@ -217,20 +217,23 @@ const MarkdownContent = ({
        const docType = chunkItem?.doc_type;

        return showImage(docType) ? (
-          <Image
-            id={imageId}
-            className={styles.referenceInnerChunkImage}
-            onClick={
-              documentId
-                ? handleDocumentButtonClick(
-                    documentId,
-                    chunkItem,
-                    fileExtension === 'pdf',
-                    documentUrl,
-                  )
-                : () => {}
-            }
-          ></Image>
+          <section>
+            <Image
+              id={imageId}
+              className={styles.referenceInnerChunkImage}
+              onClick={
+                documentId
+                  ? handleDocumentButtonClick(
+                      documentId,
+                      chunkItem,
+                      fileExtension === 'pdf',
+                      documentUrl,
+                    )
+                  : () => {}
+              }
+            ></Image>
+            <span className="text-accent-primary"> {imageId}</span>
+          </section>
        ) : (
          <HoverCard key={i}>
            <HoverCardTrigger>
--- a/web/src/components/next-markdown-content/index.tsx
+++ b/web/src/components/next-markdown-content/index.tsx
@@ -220,20 +220,23 @@ function MarkdownContent({
        const docType = chunkItem?.doc_type;

        return showImage(docType) ? (
-          <Image
-            id={imageId}
-            className={styles.referenceInnerChunkImage}
-            onClick={
-              documentId
-                ? handleDocumentButtonClick(
-                    documentId,
-                    chunkItem,
-                    fileExtension === 'pdf',
-                    documentUrl,
-                  )
-                : () => {}
-            }
-          ></Image>
+          <section>
+            <Image
+              id={imageId}
+              className={styles.referenceInnerChunkImage}
+              onClick={
+                documentId
+                  ? handleDocumentButtonClick(
+                      documentId,
+                      chunkItem,
+                      fileExtension === 'pdf',
+                      documentUrl,
+                    )
+                  : () => {}
+              }
+            ></Image>
+            <span className="text-accent-primary">{imageId}</span>
+          </section>
        ) : (
          <HoverCard key={i}>
            <HoverCardTrigger>
--- a/web/src/pages/user-setting/data-source/component/confluence-token-field.tsx
+++ b/web/src/pages/user-setting/data-source/component/confluence-token-field.tsx
@@ -0,0 +1,191 @@
+import { useEffect, useMemo } from 'react';
+import { ControllerRenderProps, useFormContext } from 'react-hook-form';
+
+import { Checkbox } from '@/components/ui/checkbox';
+import { Input } from '@/components/ui/input';
+import { cn } from '@/lib/utils';
+
+/* ---------------- Token Field ---------------- */
+
+export type ConfluenceTokenFieldProps = ControllerRenderProps & {
+  fieldType: 'username' | 'token';
+  placeholder?: string;
+  disabled?: boolean;
+};
+
+const ConfluenceTokenField = ({
+  fieldType,
+  value,
+  onChange,
+  placeholder,
+  disabled,
+  ...rest
+}: ConfluenceTokenFieldProps) => {
+  return (
+    <div className="flex w-full flex-col gap-2">
+      <Input
+        className="w-full"
+        type={fieldType === 'token' ? 'password' : 'text'}
+        value={value ?? ''}
+        onChange={(e) => onChange(e.target.value)}
+        placeholder={
+          placeholder ||
+          (fieldType === 'token'
+            ? 'Enter your Confluence access token'
+            : 'Confluence username or email')
+        }
+        disabled={disabled}
+        {...rest}
+      />
+    </div>
+  );
+};
+
+/* ---------------- Indexing Mode Field ---------------- */
+
+type ConfluenceIndexingMode = 'everything' | 'space' | 'page';
+
+export type ConfluenceIndexingModeFieldProps = ControllerRenderProps;
+
+export const ConfluenceIndexingModeField = (
+  fieldProps: ConfluenceIndexingModeFieldProps,
+) => {
+  const { value, onChange, disabled } = fieldProps;
+  const { watch, setValue } = useFormContext();
+
+  const mode = useMemo<ConfluenceIndexingMode>(
+    () => (value as ConfluenceIndexingMode) || 'everything',
+    [value],
+  );
+
+  const spaceValue = watch('config.space');
+  const pageIdValue = watch('config.page_id');
+  const indexRecursively = watch('config.index_recursively');
+
+  useEffect(() => {
+    if (!value) onChange('everything');
+  }, [value, onChange]);
+
+  const handleModeChange = (nextMode?: string) => {
+    const normalized = (nextMode || 'everything') as ConfluenceIndexingMode;
+    onChange(normalized);
+
+    if (normalized === 'everything') {
+      setValue('config.space', '', { shouldDirty: true, shouldTouch: true });
+      setValue('config.page_id', '', { shouldDirty: true, shouldTouch: true });
+      setValue('config.index_recursively', false, {
+        shouldDirty: true,
+        shouldTouch: true,
+      });
+    } else if (normalized === 'space') {
+      setValue('config.page_id', '', { shouldDirty: true, shouldTouch: true });
+      setValue('config.index_recursively', false, {
+        shouldDirty: true,
+        shouldTouch: true,
+      });
+    } else if (normalized === 'page') {
+      setValue('config.space', '', { shouldDirty: true, shouldTouch: true });
+    }
+  };
+
+  return (
+    <div className="w-full rounded-lg border border-border-button bg-bg-card p-4 space-y-4">
+      <div className="flex items-center gap-2 text-sm font-medium text-text-secondary">
+        {INDEX_MODE_OPTIONS.map((option) => {
+          const isActive = option.value === mode;
+          return (
+            <button
+              key={option.value}
+              type="button"
+              disabled={disabled}
+              onClick={() => handleModeChange(option.value)}
+              className={cn(
+                'flex-1 rounded-lg border px-3 py-2 transition-all',
+                'border-transparent bg-transparent text-text-secondary hover:border-border-button hover:bg-bg-card-secondary',
+                isActive &&
+                  'border-border-button bg-background text-primary shadow-sm',
+              )}
+            >
+              {option.label}
+            </button>
+          );
+        })}
+      </div>
+
+      {mode === 'everything' && (
+        <p className="text-sm text-text-secondary">
+          This connector will index all pages the provided credentials have
+          access to.
+        </p>
+      )}
+
+      {mode === 'space' && (
+        <div className="space-y-2">
+          <div className="text-sm font-semibold text-text-primary">
+            Space Key
+          </div>
+          <Input
+            className="w-full"
+            value={spaceValue ?? ''}
+            onChange={(e) =>
+              setValue('config.space', e.target.value, {
+                shouldDirty: true,
+                shouldTouch: true,
+              })
+            }
+            placeholder="e.g. KB"
+            disabled={disabled}
+          />
+          <p className="text-xs text-text-secondary">
+            The Confluence space key to index.
+          </p>
+        </div>
+      )}
+
+      {mode === 'page' && (
+        <div className="space-y-2">
+          <div className="text-sm font-semibold text-text-primary">Page ID</div>
+          <Input
+            className="w-full"
+            value={pageIdValue ?? ''}
+            onChange={(e) =>
+              setValue('config.page_id', e.target.value, {
+                shouldDirty: true,
+                shouldTouch: true,
+              })
+            }
+            placeholder="e.g. 123456"
+            disabled={disabled}
+          />
+          <p className="text-xs text-text-secondary">
+            The Confluence page ID to index.
+          </p>
+
+          <div className="flex items-center gap-2 pt-2">
+            <Checkbox
+              checked={Boolean(indexRecursively)}
+              onCheckedChange={(checked) =>
+                setValue('config.index_recursively', Boolean(checked), {
+                  shouldDirty: true,
+                  shouldTouch: true,
+                })
+              }
+              disabled={disabled}
+            />
+            <span className="text-sm text-text-secondary">
+              Index child pages recursively
+            </span>
+          </div>
+        </div>
+      )}
+    </div>
+  );
+};
+
+const INDEX_MODE_OPTIONS = [
+  { label: 'Everything', value: 'everything' },
+  { label: 'Space', value: 'space' },
+  { label: 'Page', value: 'page' },
+];
+
+export default ConfluenceTokenField;
--- a/web/src/pages/user-setting/data-source/contant.tsx
+++ b/web/src/pages/user-setting/data-source/contant.tsx
@@ -1,9 +1,9 @@
 import { FormFieldType } from '@/components/dynamic-form';
 import SvgIcon from '@/components/svg-icon';
 import { t } from 'i18next';
+import { ConfluenceIndexingModeField } from './component/confluence-token-field';
 import GmailTokenField from './component/gmail-token-field';
 import GoogleDriveTokenField from './component/google-drive-token-field';
-
 export enum DataSourceKey {
  CONFLUENCE = 'confluence',
  S3 = 's3',
@@ -230,12 +230,35 @@ export const DataSourceFormFields = {
      required: false,
      tooltip: t('setting.confluenceIsCloudTip'),
    },
+    {
+      label: 'Index Method',
+      name: 'config.index_mode',
+      type: FormFieldType.Text, // keep as text so RHF registers it
+      required: false,
+      horizontal: true,
+      labelClassName: 'self-start pt-4',
+      render: (fieldProps) => <ConfluenceIndexingModeField {...fieldProps} />,
+    },
    {
      label: 'Space Key',
      name: 'config.space',
      type: FormFieldType.Text,
      required: false,
-      tooltip: t('setting.confluenceSpaceKeyTip'),
+      hidden: true,
+    },
+    {
+      label: 'Page ID',
+      name: 'config.page_id',
+      type: FormFieldType.Text,
+      required: false,
+      hidden: true,
+    },
+    {
+      label: 'Index Recursively',
+      name: 'config.index_recursively',
+      type: FormFieldType.Checkbox,
+      required: false,
+      hidden: true,
    },
  ],
  [DataSourceKey.GOOGLE_DRIVE]: [
Author	SHA1	Message	Date
Ted	ad03ede7cd	fix(sdk): add cancel_all_task_of call in stop_parsing endpoint (#11748 ) ## Problem The SDK API endpoint `DELETE /datasets/{dataset_id}/chunks` only updates database status but does not send cancellation signal via Redis, causing background parsing tasks to continue and eventually complete (status becomes DONE instead of CANCEL). ## Root Cause The SDK endpoint was missing the `cancel_all_task_of(id)` call that the web API ([api/apps/document_app.py](cci:7://file:///d:/workspace1/ragflow-admin/api/apps/document_app.py:0:0-0:0)) uses to properly stop background tasks. ## Solution Added `cancel_all_task_of(id)` call in the [stop_parsing](cci:1://file:///d:/workspace1/ragflow/api/apps/sdk/doc.py:785:0-855:23) function to send cancellation signal via Redis, consistent with the web API behavior. ## Related Issue Fixes #11745 Co-authored-by: tedhappy <tedhappy@users.noreply.github.com>	2025-12-04 19:29:06 +08:00
balibabu	468e4042c2	Feat: Display the ID of the code image in the dialog. #10427 (#11746 ) ### What problem does this PR solve? Feat: Display the ID of the code image in the dialog. #10427 ### Type of change - [x] New Feature (non-breaking change which adds functionality)	2025-12-04 18:49:55 +08:00
buua436	af1344033d	Delete:remove unused tests (#11749 ) ### What problem does this PR solve? change: remove unused tests ### Type of change - [x] Bug Fix (non-breaking change which fixes an issue)	2025-12-04 18:49:32 +08:00
Magicbook1108	4012d65b3c	Feat: update front end for confluence connector (#11747 ) ### What problem does this PR solve? Feat: update front end for confluence connector ### Type of change - [x] New Feature (non-breaking change which adds functionality)	2025-12-04 18:49:13 +08:00
Magicbook1108	e2bc1a3478	Feat: add more attribute for confluence connector. (#11743 ) ### What problem does this PR solve? Feat: add more attribute for confluence connector. ### Type of change - [x] New Feature (non-breaking change which adds functionality)	2025-12-04 17:28:03 +08:00
writinwaters	6c2c447a72	Doc: Updated Create dataset descriptions (#11742 ) ### What problem does this PR solve? ### Type of change - [x] Documentation Update	2025-12-04 17:07:52 +08:00
Jin Hai	e7022db9a4	Change docker container restart policy (#11695 ) ### What problem does this PR solve? Change the restart policy from 'on-failure' to 'unless-stopped'. ### Type of change - [x] Refactoring Signed-off-by: Jin Hai <haijin.chn@gmail.com>	2025-12-04 15:18:13 +08:00
qinling0210	ca4a0ee1b2	Remove huqie.txt from RAGFflow and bump infinity to 0.6.10 (#11661 ) ### What problem does this PR solve? huqie.txt and huqie.txt.trie are put to infinity-sdk in https://github.com/infiniflow/infinity/pull/3127. Remove huqie.txt from ragflow and bump infinity to 0.6.10 in this PR. ### Type of change - [x] Refactoring	2025-12-04 14:53:57 +08:00