fix(workflow): fix missing file in non-streaming API calls

This commit is contained in:
Eternity
2026-03-19 11:06:01 +08:00
parent 68f9471caf
commit 5997458aaf
3 changed files with 5 additions and 3 deletions

View File

@@ -13,7 +13,6 @@ from app.core.logging_config import get_business_logger
from app.core.response_utils import success, fail from app.core.response_utils import success, fail
from app.db import get_db, get_db_read from app.db import get_db, get_db_read
from app.dependencies import get_share_user_id, ShareTokenData from app.dependencies import get_share_user_id, ShareTokenData
from app.models.app_model import App
from app.models.app_model import AppType from app.models.app_model import AppType
from app.repositories import knowledge_repository from app.repositories import knowledge_repository
from app.repositories.end_user_repository import EndUserRepository from app.repositories.end_user_repository import EndUserRepository
@@ -618,11 +617,11 @@ async def chat(
# 多 Agent 非流式返回 # 多 Agent 非流式返回
result = await app_chat_service.workflow_chat( result = await app_chat_service.workflow_chat(
message=payload.message, message=payload.message,
conversation_id=conversation.id, # 使用已创建的会话 ID conversation_id=conversation.id, # 使用已创建的会话 ID
user_id=end_user_id, # 转换为字符串 user_id=end_user_id, # 转换为字符串
variables=payload.variables, variables=payload.variables,
files=payload.files,
config=config, config=config,
web_search=payload.web_search, web_search=payload.web_search,
memory=payload.memory, memory=payload.memory,

View File

@@ -280,6 +280,7 @@ async def chat(
memory=memory, memory=memory,
storage_type=storage_type, storage_type=storage_type,
user_rag_memory_id=user_rag_memory_id, user_rag_memory_id=user_rag_memory_id,
files=payload.files,
app_id=app.id, app_id=app.id,
workspace_id=workspace_id, workspace_id=workspace_id,
release_id=app.current_release.id release_id=app.current_release.id

View File

@@ -585,6 +585,7 @@ class AppChatService:
app_id: uuid.UUID, app_id: uuid.UUID,
release_id: uuid.UUID, release_id: uuid.UUID,
workspace_id: uuid.UUID, workspace_id: uuid.UUID,
files: Optional[List[FileInput]] = None,
user_id: Optional[str] = None, user_id: Optional[str] = None,
variables: Optional[Dict[str, Any]] = None, variables: Optional[Dict[str, Any]] = None,
web_search: bool = False, web_search: bool = False,
@@ -598,7 +599,8 @@ class AppChatService:
variables=variables, variables=variables,
conversation_id=str(conversation_id), conversation_id=str(conversation_id),
stream=True, stream=True,
user_id=user_id user_id=user_id,
files=files
) )
return await self.workflow_service.run( return await self.workflow_service.run(
app_id=app_id, app_id=app_id,