style: auto-format with ruff [skip ci]
This commit is contained in:
parent
3973a185fa
commit
d7b6b6ca64
@ -10,7 +10,7 @@ from src import config, graph_base
|
|||||||
from src.agents.common.toolkits.registry import ToolExtraMetadata, _all_tool_instances, _extra_registry, tool
|
from src.agents.common.toolkits.registry import ToolExtraMetadata, _all_tool_instances, _extra_registry, tool
|
||||||
from src.storage.minio import aupload_file_to_minio
|
from src.storage.minio import aupload_file_to_minio
|
||||||
from src.utils import logger
|
from src.utils import logger
|
||||||
from src.utils.question_utils import normalize_questions, normalize_options
|
from src.utils.question_utils import normalize_questions
|
||||||
|
|
||||||
# Lazy initialization for TavilySearch (only when API key is available)
|
# Lazy initialization for TavilySearch (only when API key is available)
|
||||||
_tavily_search_instance = None
|
_tavily_search_instance = None
|
||||||
|
|||||||
@ -17,9 +17,10 @@ from src.repositories.conversation_repository import ConversationRepository
|
|||||||
from src.storage.postgres.manager import pg_manager
|
from src.storage.postgres.manager import pg_manager
|
||||||
from src.utils.logging_config import logger
|
from src.utils.logging_config import logger
|
||||||
from src.utils.question_utils import (
|
from src.utils.question_utils import (
|
||||||
normalize_questions as _normalize_interrupt_questions,
|
|
||||||
normalize_options as _normalize_interrupt_options,
|
normalize_options as _normalize_interrupt_options,
|
||||||
normalize_legacy_question,
|
)
|
||||||
|
from src.utils.question_utils import (
|
||||||
|
normalize_questions as _normalize_interrupt_questions,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@ -1,4 +1,5 @@
|
|||||||
"""问题和选项规范化工具"""
|
"""问题和选项规范化工具"""
|
||||||
|
|
||||||
import uuid
|
import uuid
|
||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
||||||
@ -21,9 +22,7 @@ def normalize_options(raw_options: Any) -> list[dict[str, str]]:
|
|||||||
return options
|
return options
|
||||||
|
|
||||||
|
|
||||||
def normalize_questions(
|
def normalize_questions(raw_questions: Any, default_question_id_prefix: str = "q") -> list[dict[str, Any]]:
|
||||||
raw_questions: Any, default_question_id_prefix: str = "q"
|
|
||||||
) -> list[dict[str, Any]]:
|
|
||||||
"""规范化问题列表"""
|
"""规范化问题列表"""
|
||||||
if not isinstance(raw_questions, list):
|
if not isinstance(raw_questions, list):
|
||||||
return []
|
return []
|
||||||
@ -37,9 +36,7 @@ def normalize_questions(
|
|||||||
if not question:
|
if not question:
|
||||||
continue
|
continue
|
||||||
|
|
||||||
question_id = str(
|
question_id = str(item.get("question_id") or f"{default_question_id_prefix}-{idx + 1}").strip()
|
||||||
item.get("question_id") or f"{default_question_id_prefix}-{idx + 1}"
|
|
||||||
).strip()
|
|
||||||
if not question_id:
|
if not question_id:
|
||||||
question_id = str(uuid.uuid4())
|
question_id = str(uuid.uuid4())
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user