mirror of
https://github.com/langgenius/dify.git
synced 2026-04-25 01:26:57 +08:00
refactor(api): modernize type annotations — replace Optional/Union with | syntax (#34888)
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
This commit is contained in:
parent
c41b62f47e
commit
5fafac0ca4
@ -1,6 +1,6 @@
|
|||||||
from collections.abc import Mapping, Sequence
|
from collections.abc import Mapping, Sequence
|
||||||
from enum import StrEnum
|
from enum import StrEnum
|
||||||
from typing import TYPE_CHECKING, Any, Optional
|
from typing import TYPE_CHECKING, Any
|
||||||
|
|
||||||
from graphon.file import File, FileUploadConfig
|
from graphon.file import File, FileUploadConfig
|
||||||
from graphon.model_runtime.entities.model_entities import AIModelEntity
|
from graphon.model_runtime.entities.model_entities import AIModelEntity
|
||||||
@ -131,7 +131,7 @@ class AppGenerateEntity(BaseModel):
|
|||||||
extras: dict[str, Any] = Field(default_factory=dict)
|
extras: dict[str, Any] = Field(default_factory=dict)
|
||||||
|
|
||||||
# tracing instance
|
# tracing instance
|
||||||
trace_manager: Optional["TraceQueueManager"] = Field(default=None, exclude=True, repr=False)
|
trace_manager: "TraceQueueManager | None" = Field(default=None, exclude=True, repr=False)
|
||||||
|
|
||||||
|
|
||||||
class EasyUIBasedAppGenerateEntity(AppGenerateEntity):
|
class EasyUIBasedAppGenerateEntity(AppGenerateEntity):
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
from typing import Any, Literal, Optional, TypedDict
|
from typing import Any, Literal, TypedDict
|
||||||
|
|
||||||
from graphon.model_runtime.utils.encoders import jsonable_encoder
|
from graphon.model_runtime.utils.encoders import jsonable_encoder
|
||||||
from pydantic import BaseModel, Field, field_validator
|
from pydantic import BaseModel, Field, field_validator
|
||||||
@ -17,7 +17,7 @@ class DatasourceApiEntity(BaseModel):
|
|||||||
output_schema: dict | None = None
|
output_schema: dict | None = None
|
||||||
|
|
||||||
|
|
||||||
ToolProviderTypeApiLiteral = Optional[Literal["builtin", "api", "workflow"]]
|
ToolProviderTypeApiLiteral = Literal["builtin", "api", "workflow"] | None
|
||||||
|
|
||||||
|
|
||||||
class DatasourceProviderApiEntityDict(TypedDict):
|
class DatasourceProviderApiEntityDict(TypedDict):
|
||||||
|
|||||||
@ -10,7 +10,7 @@ import uuid
|
|||||||
from collections.abc import Callable, Generator, Mapping
|
from collections.abc import Callable, Generator, Mapping
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from hashlib import sha256
|
from hashlib import sha256
|
||||||
from typing import TYPE_CHECKING, Annotated, Any, Optional, Protocol, Union, cast
|
from typing import TYPE_CHECKING, Annotated, Any, Protocol, cast
|
||||||
from uuid import UUID
|
from uuid import UUID
|
||||||
from zoneinfo import available_timezones
|
from zoneinfo import available_timezones
|
||||||
|
|
||||||
@ -81,7 +81,7 @@ def escape_like_pattern(pattern: str) -> str:
|
|||||||
return pattern.replace("\\", "\\\\").replace("%", "\\%").replace("_", "\\_")
|
return pattern.replace("\\", "\\\\").replace("%", "\\%").replace("_", "\\_")
|
||||||
|
|
||||||
|
|
||||||
def extract_tenant_id(user: Union["Account", "EndUser"]) -> str | None:
|
def extract_tenant_id(user: "Account | EndUser") -> str | None:
|
||||||
"""
|
"""
|
||||||
Extract tenant_id from Account or EndUser object.
|
Extract tenant_id from Account or EndUser object.
|
||||||
|
|
||||||
@ -164,7 +164,10 @@ def email(email):
|
|||||||
EmailStr = Annotated[str, AfterValidator(email)]
|
EmailStr = Annotated[str, AfterValidator(email)]
|
||||||
|
|
||||||
|
|
||||||
def uuid_value(value: Any) -> str:
|
def uuid_value(value: str | UUID) -> str:
|
||||||
|
if isinstance(value, UUID):
|
||||||
|
return str(value)
|
||||||
|
|
||||||
if value == "":
|
if value == "":
|
||||||
return str(value)
|
return str(value)
|
||||||
|
|
||||||
@ -405,7 +408,7 @@ class TokenManager:
|
|||||||
def generate_token(
|
def generate_token(
|
||||||
cls,
|
cls,
|
||||||
token_type: str,
|
token_type: str,
|
||||||
account: Optional["Account"] = None,
|
account: "Account | None" = None,
|
||||||
email: str | None = None,
|
email: str | None = None,
|
||||||
additional_data: dict | None = None,
|
additional_data: dict | None = None,
|
||||||
) -> str:
|
) -> str:
|
||||||
@ -465,9 +468,7 @@ class TokenManager:
|
|||||||
return current_token
|
return current_token
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def _set_current_token_for_account(
|
def _set_current_token_for_account(cls, account_id: str, token: str, token_type: str, expiry_minutes: int | float):
|
||||||
cls, account_id: str, token: str, token_type: str, expiry_minutes: Union[int, float]
|
|
||||||
):
|
|
||||||
key = cls._get_account_token_key(account_id, token_type)
|
key = cls._get_account_token_key(account_id, token_type)
|
||||||
expiry_seconds = int(expiry_minutes * 60)
|
expiry_seconds = int(expiry_minutes * 60)
|
||||||
redis_client.setex(key, expiry_seconds, token)
|
redis_client.setex(key, expiry_seconds, token)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user