sequenceDiagram
    participant WF as Workflow Execution
    participant EE as Event Emitter
    participant DB as Database
    participant AR as Alert Rules
    participant IP as Inactivity Polling
    participant ND as Notification Delivery

    Note over WF,ND: Workflow Execution Flow
    WF->>EE: emitWorkflowExecutionCompleted(log)
    EE->>DB: Query subscriptions for workspace
    DB-->>EE: Return active subscriptions
    
    loop For each subscription
        EE->>EE: Check levelFilter.includes(log.level)
        EE->>EE: Check triggerFilter.includes(log.trigger)
        alt Filters match
            EE->>AR: shouldTriggerAlert(config, context, lastAlertAt)
            AR->>DB: Query logs with triggerFilter
            Note over AR,DB: Queries now filtered by trigger types:<br/>consecutive_failures, failure_rate,<br/>latency_spike, error_count
            DB-->>AR: Historical execution data
            AR-->>EE: Alert decision
            alt Should alert
                EE->>DB: Update lastAlertAt
                EE->>ND: Create notification delivery
            end
        end
    end

    Note over IP,ND: Inactivity Polling (Hourly)
    IP->>DB: Query no_activity subscriptions
    DB-->>IP: Return subscriptions
    
    loop For each subscription
        IP->>IP: Validate triggerFilter exists
        IP->>DB: Get workflows with active deployments
        DB-->>IP: Deployed workflows with state
        IP->>IP: deploymentHasTriggerType(state, triggerFilter)
        Note over IP: Filters workflows by checking if<br/>deployment has matching trigger blocks
        IP->>DB: Query recent logs with triggerFilter
        DB-->>IP: Recent execution logs
        alt No activity in window
            IP->>DB: Update lastAlertAt
            IP->>ND: Create notification delivery
        end
    end