Post fix

Author: hyongtao-db

api/app_factory.py

@@ -19,7 +19,7 @@ def create_flask_app_with_configs() -> DifyApp:
 
     # add before request hook
     @dify_app.before_request
-    def before_request(): # pyright: ignore[reportUnusedFunction]
+    def before_request():  # pyright: ignore[reportUnusedFunction]
         # add an unique identifier to each request
         RecyclableContextVar.increment_thread_recycles()
 

api/core/extension/extension.py

@@ -42,7 +42,7 @@ def extension_class(self, module: ExtensionModule, extension_name: str) -> type:
         return t
 
     def validate_form_schema(self, module: ExtensionModule, extension_name: str, config: dict) -> None:
+        pass
         # module_extension = self.module_extension(module, extension_name)
         # form_schema = module_extension.form_schema
         # TODO validate form_schema
-        pass

api/extensions/ext_app_metrics.py

@@ -10,22 +10,22 @@
 
 def init_app(app: DifyApp):
     @app.after_request
-    def after_request(response): # pyright: ignore[reportUnusedFunction]
+    def after_request(response):  # pyright: ignore[reportUnusedFunction]
         """Add Version headers to the response."""
         response.headers.add("X-Version", dify_config.CURRENT_VERSION)
         response.headers.add("X-Env", dify_config.DEPLOY_ENV)
         return response
 
     @app.route("/health")
-    def health(): # pyright: ignore[reportUnusedFunction]
+    def health():  # pyright: ignore[reportUnusedFunction]
         return Response(
             json.dumps({"pid": os.getpid(), "status": "ok", "version": dify_config.CURRENT_VERSION}),
             status=200,
             content_type="application/json",
         )
 
     @app.route("/threads")
-    def threads(): # pyright: ignore[reportUnusedFunction]
+    def threads():  # pyright: ignore[reportUnusedFunction]
         num_threads = threading.active_count()
         threads = threading.enumerate()
 
@@ -50,7 +50,7 @@ def threads(): # pyright: ignore[reportUnusedFunction]
         }
 
     @app.route("/db-pool-stat")
-    def pool_stat(): # pyright: ignore[reportUnusedFunction]
+    def pool_stat():  # pyright: ignore[reportUnusedFunction]
         from extensions.ext_database import db
 
         engine = db.engine

api/tasks/batch_create_segment_to_index_task.py

@@ -5,7 +5,7 @@
 
 import click
 from celery import shared_task  # type: ignore
-from sqlalchemy import func, select
+from sqlalchemy import func
 from sqlalchemy.orm import Session
 
 from core.model_manager import ModelManager

api/tests/integration_tests/vdb/opengauss/test_opengauss.py

@@ -1,6 +1,6 @@
 import time
 
-import psycopg2 # type: ignore
+import psycopg2  # type: ignore
 
 from core.rag.datasource.vdb.opengauss.opengauss import OpenGauss, OpenGaussConfig
 from tests.integration_tests.vdb.test_vector_store import (

api/tests/unit_tests/conftest.py

@@ -18,6 +18,6 @@ def app() -> Flask:
 
 
 @pytest.fixture(autouse=True)
-def _provide_app_context(app: Flask): # pyright: ignore[reportUnusedFunction]
+def _provide_app_context(app: Flask):  # pyright: ignore[reportUnusedFunction]
     with app.app_context():
         yield