jandres/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-01-07 23:04:12 +00:00
Code Issues Actions 10 Packages Projects Releases Wiki Activity

- refactor(services): move ConversationVariableUpdaterImpl and factory out of core.workflow into api/services/conversation_variable_updater.py

Browse Source 
- refactor(app): update advanced chat app runner and conversation service to import the new updater factory

Tests not run.
This commit is contained in:
-LAN-
2026-01-05 14:32:11 +08:00
parent 2831694e2e
commit b083fa2315
3 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/core/app/apps/advanced_chat/app_runner.py
View File

@@ -28,7 +28,7 @@ from core.workflow.enums import WorkflowType
from core.workflow.graph_engine.command_channels.redis_channel import RedisChannel
from core.workflow.graph_engine.layers.base import GraphEngineLayer
from core.workflow.graph_engine.layers.persistence import PersistenceWorkflowInfo, WorkflowPersistenceLayer
from core.workflow.nodes.variable_assigner.common.impl import conversation_variable_updater_factory
from services.conversation_variable_updater import conversation_variable_updater_factory
from core.workflow.repositories.workflow_execution_repository import WorkflowExecutionRepository
from core.workflow.repositories.workflow_node_execution_repository import WorkflowNodeExecutionRepository
from core.workflow.runtime import GraphRuntimeState, VariablePool

2
api/services/conversation_service.py
View File

@@ -11,7 +11,7 @@ from core.app.entities.app_invoke_entities import InvokeFrom
from core.db.session_factory import session_factory
from core.llm_generator.llm_generator import LLMGenerator
from core.variables.types import SegmentType
from core.workflow.nodes.variable_assigner.common.impl import conversation_variable_updater_factory
from services.conversation_variable_updater import conversation_variable_updater_factory
from extensions.ext_database import db
from factories import variable_factory
from libs.datetime_utils import naive_utc_now

4
api/core/workflow/nodes/variable_assigner/common/impl.py → api/services/conversation_variable_updater.py
View File

@@ -5,8 +5,6 @@ from core.variables.variables import Variable
from extensions.ext_database import db
from models import ConversationVariable
from .exc import VariableOperatorNodeError
class ConversationVariableUpdaterImpl:
def update(self, conversation_id: str, variable: Variable):
@@ -16,7 +14,7 @@ class ConversationVariableUpdaterImpl:
with Session(db.engine) as session:
row = session.scalar(stmt)
if not row:
raise VariableOperatorNodeError("conversation variable not found in the database")
raise ValueError("conversation variable not found in the database")
row.data = variable.model_dump_json()
session.commit()