[FIX]Ruff: lint errors for E731

api/.ruff.toml

@@ -46,7 +46,6 @@ ignore = [
     "E712", # true-false-comparison
     "E721", # type-comparison
     "E722", # bare-except
-    "E731", # lambda-assignment
     "F821", # undefined-name
     "F841", # unused-variable
     "FURB113", # repeated-append

api/core/tools/tool_manager.py

@@ -464,9 +464,8 @@ def user_list_providers(
                 db.session.query(BuiltinToolProvider).filter(BuiltinToolProvider.tenant_id == tenant_id).all()
             )
 
-            find_db_builtin_provider = lambda provider: next(
-                (x for x in db_builtin_providers if x.provider == provider), None
-            )
+            def find_db_builtin_provider(provider):
+                return next((x for x in db_builtin_providers if x.provider == provider), None)
 
             # append builtin providers
             for provider in builtin_providers:

api/models/workflow.py

@@ -249,11 +249,12 @@ def environment_variables(self) -> Sequence[Variable]:
         ]
 
         # decrypt secret variables value
-        decrypt_func = (
-            lambda var: var.model_copy(update={"value": encrypter.decrypt_token(tenant_id=tenant_id, token=var.value)})
-            if isinstance(var, SecretVariable)
-            else var
-        )
+        def decrypt_func(var):
+            if isinstance(var, SecretVariable):
+                return var.model_copy(update={"value": encrypter.decrypt_token(tenant_id=tenant_id, token=var.value)})
+            else:
+                return var
+
         results = list(map(decrypt_func, results))
         return results
 
@@ -277,11 +278,12 @@ def environment_variables(self, value: Sequence[Variable]):
                 value[i] = origin_variables_dictionary[variable.id].model_copy(update={"name": variable.name})
 
         # encrypt secret variables value
-        encrypt_func = (
-            lambda var: var.model_copy(update={"value": encrypter.encrypt_token(tenant_id=tenant_id, token=var.value)})
-            if isinstance(var, SecretVariable)
-            else var
-        )
+        def encrypt_func(var):
+            if isinstance(var, SecretVariable):
+                return var.model_copy(update={"value": encrypter.encrypt_token(tenant_id=tenant_id, token=var.value)})
+            else:
+                return var
+
         encrypted_vars = list(map(encrypt_func, value))
         environment_variables_json = json.dumps(
             {var.name: var.model_dump() for var in encrypted_vars},

api/services/tools/builtin_tools_manage_service.py

@@ -201,9 +201,8 @@ def list_builtin_tools(user_id: str, tenant_id: str) -> list[UserToolProvider]:
         )
 
         # find provider
-        find_provider = lambda provider: next(
-            filter(lambda db_provider: db_provider.provider == provider, db_providers), None
-        )
+        def find_provider(provider):
+            return next(filter(lambda db_provider: db_provider.provider == provider, db_providers), None)
 
         result: list[UserToolProvider] = []