From 8fd088754a5d04fb045db3ba2aabc7a391964baa Mon Sep 17 00:00:00 2001 From: Stream Date: Sat, 11 Oct 2025 16:15:32 +0800 Subject: [PATCH 1/2] fix: fix circular ref --- api/core/workflow/nodes/llm/node.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/api/core/workflow/nodes/llm/node.py b/api/core/workflow/nodes/llm/node.py index 11d592b24e..6483a5c593 100644 --- a/api/core/workflow/nodes/llm/node.py +++ b/api/core/workflow/nodes/llm/node.py @@ -77,7 +77,6 @@ from core.workflow.nodes.base.node import Node from core.workflow.nodes.base.variable_template_parser import VariableTemplateParser from models import UserFrom, Workflow from models.engine import db -from services.chatflow_memory_service import ChatflowMemoryService from . import llm_utils from .entities import ( @@ -1251,6 +1250,7 @@ class LLMNode(Node): if memory_block_spec and memory_block_spec.scope == MemoryScope.NODE: is_draft = (self.invoke_from == InvokeFrom.DEBUGGER) + from services.chatflow_memory_service import ChatflowMemoryService ChatflowMemoryService.update_node_memory_if_needed( tenant_id=self.tenant_id, app_id=self.app_id, From f4567fbf9e9f0325621572ad3cd3ced8f03b1a98 Mon Sep 17 00:00:00 2001 From: Stream Date: Sat, 11 Oct 2025 16:27:40 +0800 Subject: [PATCH 2/2] fix: fix circular ref --- api/services/workflow_service.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/api/services/workflow_service.py b/api/services/workflow_service.py index 4137f2df91..5a2b6e8f56 100644 --- a/api/services/workflow_service.py +++ b/api/services/workflow_service.py @@ -40,7 +40,6 @@ from services.enterprise.plugin_manager_service import PluginCredentialType from services.errors.app import IsDraftWorkflowError, WorkflowHashNotEqualError from services.workflow.workflow_converter import WorkflowConverter -from .chatflow_memory_service import ChatflowMemoryService from .errors.workflow_service import DraftWorkflowDeletionError, WorkflowInUseError from .workflow_draft_variable_service import DraftVariableSaver, DraftVarLoader, WorkflowDraftVariableService @@ -1068,6 +1067,7 @@ def _fetch_memory_blocks( ) -> Mapping[str, str]: memory_blocks = {} memory_block_specs = workflow.memory_blocks + from services.chatflow_memory_service import ChatflowMemoryService memories = ChatflowMemoryService.get_memories_by_specs( memory_block_specs=memory_block_specs, tenant_id=workflow.tenant_id,