fix: import graphon.

api/controllers/console/evaluation/evaluation.py

@@ -21,7 +21,7 @@ from controllers.console.wraps import (
     setup_required,
 )
 from core.evaluation.entities.evaluation_entity import EvaluationCategory, EvaluationConfigData, EvaluationRunRequest
-from dify_graph.file import helpers as file_helpers
+from graphon.file import helpers as file_helpers
 from extensions.ext_database import db
 from extensions.ext_storage import storage
 from libs.helper import TimestampField

api/controllers/console/snippets/snippet_workflow.py

@@ -34,7 +34,7 @@ from controllers.console.wraps import (
 )
 from core.app.apps.base_app_queue_manager import AppQueueManager
 from core.app.entities.app_invoke_entities import InvokeFrom
-from dify_graph.graph_engine.manager import GraphEngineManager
+from graphon.graph_engine.manager import GraphEngineManager
 from extensions.ext_database import db
 from extensions.ext_redis import redis_client
 from factories import variable_factory

api/core/evaluation/base_evaluation_instance.py

@@ -10,7 +10,7 @@ from core.evaluation.entities.evaluation_entity import (
     EvaluationItemResult,
     EvaluationMetric,
 )
-from dify_graph.node_events.base import NodeRunResult
+from graphon.node_events.base import NodeRunResult
 
 logger = logging.getLogger(__name__)
 
@@ -162,7 +162,7 @@ class BaseEvaluationInstance(ABC):
             ``node_run_result_mapping``.
 
         """
-        from dify_graph.nodes.base.variable_template_parser import REGEX as VARIABLE_REGEX
+        from graphon.nodes.base.variable_template_parser import REGEX as VARIABLE_REGEX
 
         workflow_inputs: dict[str, Any] = {}
 

api/core/evaluation/judgment/processor.py

@@ -23,8 +23,8 @@ from core.evaluation.entities.judgment_entity import (
     JudgmentConfig,
     JudgmentResult,
 )
-from dify_graph.utils.condition.entities import SupportedComparisonOperator
-from dify_graph.utils.condition.processor import _evaluate_condition  # pyright: ignore[reportPrivateUsage]
+from graphon.utils.condition.entities import SupportedComparisonOperator
+from graphon.utils.condition.processor import _evaluate_condition  # pyright: ignore[reportPrivateUsage]
 
 logger = logging.getLogger(__name__)
 

api/core/evaluation/runners/agent_evaluation_runner.py

@@ -12,7 +12,7 @@ from core.evaluation.entities.evaluation_entity import (
     EvaluationItemResult,
 )
 from core.evaluation.runners.base_evaluation_runner import BaseEvaluationRunner
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 from models.model import App
 
 logger = logging.getLogger(__name__)

api/core/evaluation/runners/base_evaluation_runner.py

@@ -26,7 +26,7 @@ from core.evaluation.entities.evaluation_entity import (
 )
 from core.evaluation.entities.judgment_entity import JudgmentConfig
 from core.evaluation.judgment.processor import JudgmentProcessor
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 from libs.datetime_utils import naive_utc_now
 from models.evaluation import EvaluationRun, EvaluationRunItem, EvaluationRunStatus
 

api/core/evaluation/runners/llm_evaluation_runner.py

@@ -12,7 +12,7 @@ from core.evaluation.entities.evaluation_entity import (
     EvaluationItemResult,
 )
 from core.evaluation.runners.base_evaluation_runner import BaseEvaluationRunner
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 
 logger = logging.getLogger(__name__)
 

api/core/evaluation/runners/retrieval_evaluation_runner.py

@@ -11,7 +11,7 @@ from core.evaluation.entities.evaluation_entity import (
     EvaluationItemResult,
 )
 from core.evaluation.runners.base_evaluation_runner import BaseEvaluationRunner
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 
 logger = logging.getLogger(__name__)
 

api/core/evaluation/runners/snippet_evaluation_runner.py

@@ -22,7 +22,7 @@ from core.evaluation.entities.evaluation_entity import (
     EvaluationItemResult,
 )
 from core.evaluation.runners.base_evaluation_runner import BaseEvaluationRunner
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 from models.snippet import CustomizedSnippet
 from models.workflow import WorkflowNodeExecutionModel
 

api/core/evaluation/runners/workflow_evaluation_runner.py

@@ -12,7 +12,7 @@ from core.evaluation.entities.evaluation_entity import (
     EvaluationItemResult,
 )
 from core.evaluation.runners.base_evaluation_runner import BaseEvaluationRunner
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 
 logger = logging.getLogger(__name__)
 

api/services/evaluation_service.py

@@ -22,8 +22,8 @@ from core.evaluation.entities.evaluation_entity import (
     NodeInfo,
 )
 from core.evaluation.evaluation_manager import EvaluationManager
-from dify_graph.enums import WorkflowNodeExecutionMetadataKey
-from dify_graph.node_events.base import NodeRunResult
+from graphon.enums import WorkflowNodeExecutionMetadataKey
+from graphon.node_events.base import NodeRunResult
 from models.evaluation import (
     EvaluationConfiguration,
     EvaluationRun,
@@ -727,7 +727,7 @@ class EvaluationService:
         """Query all node execution records for a workflow run."""
         from sqlalchemy import asc, select
 
-        from dify_graph.enums import WorkflowNodeExecutionStatus
+        from graphon.enums import WorkflowNodeExecutionStatus
         from models.workflow import WorkflowNodeExecutionModel
 
         stmt = (

api/services/snippet_dsl_service.py

@@ -14,8 +14,8 @@ from sqlalchemy.orm import Session
 
 from core.helper import ssrf_proxy
 from core.plugin.entities.plugin import PluginDependency
-from dify_graph.enums import BuiltinNodeTypes
-from dify_graph.model_runtime.utils.encoders import jsonable_encoder
+from graphon.enums import BuiltinNodeTypes
+from graphon.model_runtime.utils.encoders import jsonable_encoder
 from extensions.ext_redis import redis_client
 from factories import variable_factory
 from models import Account

api/services/snippet_generate_service.py

@@ -28,7 +28,7 @@ from sqlalchemy.orm import make_transient
 from core.app.app_config.features.file_upload.manager import FileUploadConfigManager
 from core.app.apps.workflow.app_generator import WorkflowAppGenerator
 from core.app.entities.app_invoke_entities import InvokeFrom
-from dify_graph.file.models import File
+from graphon.file.models import File
 from factories import file_factory
 from models import Account
 from models.model import AppMode, EndUser

api/services/snippet_service.py

@@ -8,8 +8,8 @@ from sqlalchemy import func, select
 from sqlalchemy.orm import Session, sessionmaker
 
 from core.workflow.node_factory import LATEST_VERSION, NODE_TYPE_CLASSES_MAPPING
-from dify_graph.enums import NodeType
-from dify_graph.variables.variables import VariableBase
+from graphon.enums import NodeType
+from graphon.variables.variables import VariableBase
 from extensions.ext_database import db
 from libs.infinite_scroll_pagination import InfiniteScrollPagination
 from models import Account

api/tasks/evaluation_task.py

@@ -24,7 +24,7 @@ from core.evaluation.runners.llm_evaluation_runner import LLMEvaluationRunner
 from core.evaluation.runners.retrieval_evaluation_runner import RetrievalEvaluationRunner
 from core.evaluation.runners.snippet_evaluation_runner import SnippetEvaluationRunner
 from core.evaluation.runners.workflow_evaluation_runner import WorkflowEvaluationRunner
-from dify_graph.node_events import NodeRunResult
+from graphon.node_events import NodeRunResult
 from extensions.ext_database import db
 from libs.datetime_utils import naive_utc_now
 from models.enums import CreatorUserRole