Skip to content

Commit

Permalink
chore: cleanup unchanged overridden method in subclasses of BaseNode (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
bowenliang123 authored Feb 26, 2025
1 parent 93a5ffb commit 21e1443
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 69 deletions.
20 changes: 0 additions & 20 deletions api/core/workflow/nodes/end/end_node.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,3 @@
from collections.abc import Mapping, Sequence
from typing import Any

from core.workflow.entities.node_entities import NodeRunResult
from core.workflow.nodes.base import BaseNode
from core.workflow.nodes.end.entities import EndNodeData
Expand Down Expand Up @@ -30,20 +27,3 @@ def _run(self) -> NodeRunResult:
inputs=outputs,
outputs=outputs,
)

@classmethod
def _extract_variable_selector_to_variable_mapping(
cls,
*,
graph_config: Mapping[str, Any],
node_id: str,
node_data: EndNodeData,
) -> Mapping[str, Sequence[str]]:
"""
Extract variable selector to variable mapping
:param graph_config: graph config
:param node_id: node id
:param node_data: node data
:return:
"""
return {}
20 changes: 1 addition & 19 deletions api/core/workflow/nodes/if_else/if_else_node.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
from collections.abc import Mapping, Sequence
from typing import Any, Literal
from typing import Literal

from typing_extensions import deprecated

Expand Down Expand Up @@ -88,23 +87,6 @@ def _run(self) -> NodeRunResult:

return data

@classmethod
def _extract_variable_selector_to_variable_mapping(
cls,
*,
graph_config: Mapping[str, Any],
node_id: str,
node_data: IfElseNodeData,
) -> Mapping[str, Sequence[str]]:
"""
Extract variable selector to variable mapping
:param graph_config: graph config
:param node_id: node id
:param node_data: node data
:return:
"""
return {}


@deprecated("This function is deprecated. You should use the new cases structure.")
def _should_not_use_old_function(
Expand Down
18 changes: 1 addition & 17 deletions api/core/workflow/nodes/iteration/iteration_start_node.py
Original file line number Diff line number Diff line change
@@ -1,10 +1,7 @@
from collections.abc import Mapping, Sequence
from typing import Any

from core.workflow.entities.node_entities import NodeRunResult
from core.workflow.nodes.base import BaseNode
from core.workflow.nodes.enums import NodeType
from core.workflow.nodes.iteration.entities import IterationNodeData, IterationStartNodeData
from core.workflow.nodes.iteration.entities import IterationStartNodeData
from models.workflow import WorkflowNodeExecutionStatus


Expand All @@ -21,16 +18,3 @@ def _run(self) -> NodeRunResult:
Run the node.
"""
return NodeRunResult(status=WorkflowNodeExecutionStatus.SUCCEEDED)

@classmethod
def _extract_variable_selector_to_variable_mapping(
cls, graph_config: Mapping[str, Any], node_id: str, node_data: IterationNodeData
) -> Mapping[str, Sequence[str]]:
"""
Extract variable selector to variable mapping
:param graph_config: graph config
:param node_id: node id
:param node_data: node data
:return:
"""
return {}
13 changes: 0 additions & 13 deletions api/core/workflow/nodes/start/start_node.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,3 @@
from collections.abc import Mapping, Sequence
from typing import Any

from core.workflow.constants import SYSTEM_VARIABLE_NODE_ID
from core.workflow.entities.node_entities import NodeRunResult
from core.workflow.nodes.base import BaseNode
Expand All @@ -23,13 +20,3 @@ def _run(self) -> NodeRunResult:
node_inputs[SYSTEM_VARIABLE_NODE_ID + "." + var] = system_inputs[var]

return NodeRunResult(status=WorkflowNodeExecutionStatus.SUCCEEDED, inputs=node_inputs, outputs=node_inputs)

@classmethod
def _extract_variable_selector_to_variable_mapping(
cls,
*,
graph_config: Mapping[str, Any],
node_id: str,
node_data: StartNodeData,
) -> Mapping[str, Sequence[str]]:
return {}

0 comments on commit 21e1443

Please sign in to comment.