fix(api): send the node state snapshots while reestablish subscription

This commit is contained in:
QuantumGhost
2026-01-21 09:51:34 +08:00
parent 70f12ad310
commit b529c78882
3 changed files with 15 additions and 5 deletions

View File

@ -12,8 +12,8 @@ from core.app.entities.app_invoke_entities import InvokeFrom
from core.app.entities.queue_entities import QueueTextChunkEvent, QueueWorkflowPausedEvent
from core.workflow.entities.pause_reason import HumanInputRequired
from models.enums import MessageStatus
from models.model import EndUser
from models.execution_extra_content import HumanInputContent
from models.model import EndUser
def _build_pipeline() -> pipeline_module.AdvancedChatAppGenerateTaskPipeline: