This commit is contained in:
takatost 2024-03-04 23:34:28 +08:00
parent 75f1355d4c
commit bc4edbfc2b
5 changed files with 6 additions and 6 deletions

View File

@ -1,6 +1,6 @@
from core.app.app_queue_manager import AppQueueManager, PublishFrom from core.app.app_queue_manager import AppQueueManager, PublishFrom
from core.workflow.callbacks.base_callback import BaseWorkflowCallback from core.workflow.callbacks.base_callback import BaseWorkflowCallback
from models.workflow import WorkflowRun, WorkflowNodeExecution from models.workflow import WorkflowNodeExecution, WorkflowRun
class WorkflowEventTriggerCallback(BaseWorkflowCallback): class WorkflowEventTriggerCallback(BaseWorkflowCallback):

View File

@ -1,6 +1,6 @@
from abc import abstractmethod from abc import abstractmethod
from models.workflow import WorkflowRun, WorkflowNodeExecution from models.workflow import WorkflowNodeExecution, WorkflowRun
class BaseWorkflowCallback: class BaseWorkflowCallback:

View File

@ -1,5 +1,5 @@
from abc import abstractmethod from abc import abstractmethod
from typing import Optional, Type from typing import Optional
from core.workflow.entities.base_node_data_entities import BaseNodeData from core.workflow.entities.base_node_data_entities import BaseNodeData
from core.workflow.entities.node_entities import NodeType from core.workflow.entities.node_entities import NodeType
@ -8,7 +8,7 @@ from core.workflow.entities.variable_pool import VariablePool
class BaseNode: class BaseNode:
_node_type: NodeType _node_type: NodeType
_node_data_cls: Type[BaseNodeData] _node_data_cls: type[BaseNodeData]
def __init__(self, config: dict) -> None: def __init__(self, config: dict) -> None:
self._node_id = config.get("id") self._node_id = config.get("id")

View File

@ -1,4 +1,4 @@
from typing import Type, Optional from typing import Optional
from core.workflow.entities.node_entities import NodeType from core.workflow.entities.node_entities import NodeType
from core.workflow.entities.variable_pool import VariablePool from core.workflow.entities.variable_pool import VariablePool

View File

@ -19,7 +19,7 @@ from core.workflow.nodes.variable_assigner.variable_assigner_node import Variabl
from extensions.ext_database import db from extensions.ext_database import db
from models.account import Account from models.account import Account
from models.model import App, EndUser from models.model import App, EndUser
from models.workflow import Workflow, WorkflowRunTriggeredFrom, WorkflowRun, WorkflowRunStatus, CreatedByRole from models.workflow import CreatedByRole, Workflow, WorkflowRun, WorkflowRunStatus, WorkflowRunTriggeredFrom
node_classes = { node_classes = {
NodeType.START: StartNode, NodeType.START: StartNode,