Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
30863d2208 |
@ -2,6 +2,7 @@ import json
|
|||||||
from collections.abc import Sequence
|
from collections.abc import Sequence
|
||||||
from typing import Any, cast
|
from typing import Any, cast
|
||||||
|
|
||||||
|
from core.app.entities.app_invoke_entities import InvokeFrom
|
||||||
from core.variables import SegmentType, Variable
|
from core.variables import SegmentType, Variable
|
||||||
from core.workflow.constants import CONVERSATION_VARIABLE_NODE_ID
|
from core.workflow.constants import CONVERSATION_VARIABLE_NODE_ID
|
||||||
from core.workflow.entities.node_entities import NodeRunResult
|
from core.workflow.entities.node_entities import NodeRunResult
|
||||||
@ -123,6 +124,7 @@ class VariableAssignerNode(BaseNode[VariableAssignerNodeData]):
|
|||||||
if variable.selector[0] == CONVERSATION_VARIABLE_NODE_ID:
|
if variable.selector[0] == CONVERSATION_VARIABLE_NODE_ID:
|
||||||
conversation_id = self.graph_runtime_state.variable_pool.get(["sys", "conversation_id"])
|
conversation_id = self.graph_runtime_state.variable_pool.get(["sys", "conversation_id"])
|
||||||
if not conversation_id:
|
if not conversation_id:
|
||||||
|
if self.invoke_from != InvokeFrom.DEBUGGER:
|
||||||
raise ConversationIDNotFoundError
|
raise ConversationIDNotFoundError
|
||||||
else:
|
else:
|
||||||
conversation_id = conversation_id.value
|
conversation_id = conversation_id.value
|
||||||
@ -131,6 +133,7 @@ class VariableAssignerNode(BaseNode[VariableAssignerNodeData]):
|
|||||||
variable=variable,
|
variable=variable,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
return NodeRunResult(
|
return NodeRunResult(
|
||||||
status=WorkflowNodeExecutionStatus.SUCCEEDED,
|
status=WorkflowNodeExecutionStatus.SUCCEEDED,
|
||||||
inputs=inputs,
|
inputs=inputs,
|
||||||
|
Loading…
Reference in New Issue
Block a user