From 34ef10c81891ca9db8b523ef6631dca143948810 Mon Sep 17 00:00:00 2001 From: -LAN- Date: Sat, 14 Mar 2026 18:51:39 +0800 Subject: [PATCH] Keep direct provider_id consumers unchanged --- api/core/app/apps/workflow_app_runner.py | 8 ++------ api/core/app/entities/queue_entities.py | 1 - api/core/app/entities/task_entities.py | 2 -- .../common/test_workflow_response_converter_truncation.py | 1 - 4 files changed, 2 insertions(+), 10 deletions(-) diff --git a/api/core/app/apps/workflow_app_runner.py b/api/core/app/apps/workflow_app_runner.py index 28dab3e400..252faf7e3e 100644 --- a/api/core/app/apps/workflow_app_runner.py +++ b/api/core/app/apps/workflow_app_runner.py @@ -392,7 +392,6 @@ class WorkflowBasedAppRunner: process_data = node_run_result.process_data outputs = node_run_result.outputs execution_metadata = node_run_result.metadata - provider_id = event.provider_id or str(event.extras.get("provider_id", "")) self._publish_event( QueueNodeRetryEvent( node_execution_id=event.id, @@ -408,13 +407,11 @@ class WorkflowBasedAppRunner: error=event.error, execution_metadata=execution_metadata, retry_index=event.retry_index, - extras=dict(event.extras), provider_type=event.provider_type, - provider_id=provider_id, + provider_id=event.provider_id, ) ) elif isinstance(event, NodeRunStartedEvent): - provider_id = event.provider_id or str(event.extras.get("provider_id", "")) self._publish_event( QueueNodeStartedEvent( node_execution_id=event.id, @@ -425,9 +422,8 @@ class WorkflowBasedAppRunner: in_iteration_id=event.in_iteration_id, in_loop_id=event.in_loop_id, agent_strategy=event.agent_strategy, - extras=dict(event.extras), provider_type=event.provider_type, - provider_id=provider_id, + provider_id=event.provider_id, ) ) elif isinstance(event, NodeRunSucceededEvent): diff --git a/api/core/app/entities/queue_entities.py b/api/core/app/entities/queue_entities.py index daaf2a6a39..e8b7955935 100644 --- a/api/core/app/entities/queue_entities.py +++ b/api/core/app/entities/queue_entities.py @@ -315,7 +315,6 @@ class QueueNodeStartedEvent(AppQueueEvent): in_loop_id: str | None = None start_at: datetime agent_strategy: AgentNodeStrategyInit | None = None - extras: dict[str, object] = Field(default_factory=dict) # Legacy provider fields kept for existing start-event consumers. provider_type: str # should be a core.tools.entities.tool_entities.ToolProviderType diff --git a/api/core/app/entities/task_entities.py b/api/core/app/entities/task_entities.py index 9d3d63d712..b58dae0ff2 100644 --- a/api/core/app/entities/task_entities.py +++ b/api/core/app/entities/task_entities.py @@ -472,7 +472,6 @@ class NodeRetryStreamResponse(StreamResponse): iteration_id: str | None = None loop_id: str | None = None retry_index: int = 0 - extras: dict[str, object] = Field(default_factory=dict) event: StreamEvent = StreamEvent.NODE_RETRY workflow_run_id: str @@ -503,7 +502,6 @@ class NodeRetryStreamResponse(StreamResponse): "iteration_id": self.data.iteration_id, "loop_id": self.data.loop_id, "retry_index": self.data.retry_index, - "extras": {}, }, } diff --git a/api/tests/unit_tests/core/app/apps/common/test_workflow_response_converter_truncation.py b/api/tests/unit_tests/core/app/apps/common/test_workflow_response_converter_truncation.py index d4eaf2e498..21e758b91b 100644 --- a/api/tests/unit_tests/core/app/apps/common/test_workflow_response_converter_truncation.py +++ b/api/tests/unit_tests/core/app/apps/common/test_workflow_response_converter_truncation.py @@ -737,7 +737,6 @@ class TestWorkflowResponseConverterServiceApiTruncation: assert not response.data.inputs_truncated assert not response.data.process_data_truncated assert not response.data.outputs_truncated - assert response.data.extras == {} def test_trigger_plugin_start_event_uses_provider_id_for_icon(self): converter = self.create_test_converter(InvokeFrom.WEB_APP)