opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-29 12:37:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: workflow log missing trigger icon (#29379)

Browse Source
This commit is contained in:
非法操作 2025-12-10 10:15:21 +08:00 committed by GitHub
parent e205182e1f
commit 7df360a292
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
api/models/workflow.py
View File

@ -907,19 +907,29 @@ class WorkflowNodeExecutionModel(Base): # This model is expected to have `offlo
@property @property
def extras(self) -> dict[str, Any]: def extras(self) -> dict[str, Any]:
from core.tools.tool_manager import ToolManager from core.tools.tool_manager import ToolManager
from core.trigger.trigger_manager import TriggerManager
extras: dict[str, Any] = {} extras: dict[str, Any] = {}
if self.execution_metadata_dict: execution_metadata = self.execution_metadata_dict
if self.node_type == NodeType.TOOL and "tool_info" in self.execution_metadata_dict: if execution_metadata:
tool_info: dict[str, Any] = self.execution_metadata_dict["tool_info"] if self.node_type == NodeType.TOOL and "tool_info" in execution_metadata:
tool_info: dict[str, Any] = execution_metadata["tool_info"]
extras["icon"] = ToolManager.get_tool_icon( extras["icon"] = ToolManager.get_tool_icon(
tenant_id=self.tenant_id, tenant_id=self.tenant_id,
provider_type=tool_info["provider_type"], provider_type=tool_info["provider_type"],
provider_id=tool_info["provider_id"], provider_id=tool_info["provider_id"],
) )
elif self.node_type == NodeType.DATASOURCE and "datasource_info" in self.execution_metadata_dict: elif self.node_type == NodeType.DATASOURCE and "datasource_info" in execution_metadata:
datasource_info = self.execution_metadata_dict["datasource_info"] datasource_info = execution_metadata["datasource_info"]
extras["icon"] = datasource_info.get("icon") extras["icon"] = datasource_info.get("icon")
elif self.node_type == NodeType.TRIGGER_PLUGIN and "trigger_info" in execution_metadata:
trigger_info = execution_metadata["trigger_info"] or {}
provider_id = trigger_info.get("provider_id")
if provider_id:
extras["icon"] = TriggerManager.get_trigger_plugin_icon(
tenant_id=self.tenant_id,
provider_id=provider_id,
)
return extras return extras
def _get_offload_by_type(self, type_: ExecutionOffLoadType) -> Optional["WorkflowNodeExecutionOffload"]: def _get_offload_by_type(self, type_: ExecutionOffLoadType) -> Optional["WorkflowNodeExecutionOffload"]: