sequenceDiagram
    participant User
    participant useWorkflowExecution
    participant ExecutionStream
    participant WorkflowStore
    participant ExecutionStore
    participant Console
    participant Server
    participant QueryClient

    User->>useWorkflowExecution: "handleRunWorkflow(workflowInput)"
    
    useWorkflowExecution->>WorkflowStore: "Get workflow state"
    WorkflowStore-->>useWorkflowExecution: "blocks, edges"
    
    useWorkflowExecution->>ExecutionStore: "setIsExecuting(true)"
    
    useWorkflowExecution->>useWorkflowExecution: "executeWorkflow()"
    
    useWorkflowExecution->>useWorkflowExecution: "Resolve triggers and validate"
    
    useWorkflowExecution->>ExecutionStream: "execute({workflowId, input, startBlockId})"
    
    ExecutionStream->>Server: "POST /api/workflows/execute"
    Server-->>ExecutionStream: "Stream response"
    
    loop For each streaming event
        ExecutionStream->>useWorkflowExecution: "onBlockStarted(blockData)"
        useWorkflowExecution->>ExecutionStore: "setActiveBlocks(blockId)"
        useWorkflowExecution->>ExecutionStore: "setEdgeRunStatus(edgeId, 'success')"
        
        ExecutionStream->>useWorkflowExecution: "onBlockCompleted(blockData)"
        useWorkflowExecution->>ExecutionStore: "setBlockRunStatus(blockId, 'success')"
        useWorkflowExecution->>Console: "addConsole(blockResult)"
        
        alt If streaming block
            ExecutionStream->>useWorkflowExecution: "onStreamChunk(data)"
        end
    end
    
    ExecutionStream->>useWorkflowExecution: "onExecutionCompleted(result)"
    useWorkflowExecution->>useWorkflowExecution: "setExecutionResult(result)"
    
    useWorkflowExecution->>QueryClient: "invalidateQueries(subscriptionKeys)"
    
    useWorkflowExecution->>ExecutionStore: "setIsExecuting(false)"
    useWorkflowExecution->>ExecutionStore: "setActiveBlocks(new Set())"
    
    useWorkflowExecution-->>User: "Return execution result"