Linear urgent unassigned issue triage sentinel

id: linear-urgent-unassigned-issue-triage-sentinel
namespace: company.operations

inputs:
  - id: team_key
    type: STRING
    displayName: Linear Team Key
    defaults: "ENG"
    description: Linear team key identifier (e.g. 'ENG', 'OPS', 'SEC') used to
      filter issues.

  - id: lookback_limit
    type: INT
    displayName: Issue Evaluation Limit
    defaults: 25
    description: Maximum number of urgent issues to inspect in the triage queue per
      execution.

  - id: fail_on_unassigned_urgent
    type: BOOL
    displayName: Fail on Unassigned Urgent Issues
    defaults: false
    description: Whether to fail execution when unassigned urgent issues are
      detected to trip external pager services.

triggers:
  - id: recurring_triage_sweep
    type: io.kestra.plugin.core.trigger.Schedule
    description: Frequent 15-minute triage audit to catch unassigned urgent tickets
      before SLA breach. Shipped disabled by default.
    cron: "*/15 * * * *"
    disabled: true

tasks:
  - id: fetch_urgent_unassigned_issues
    type: io.kestra.plugin.graphql.Request
    description: Query Linear GraphQL API for urgent priority issues lacking an
      assigned engineer.
    uri: "https://api.linear.app/graphql"
    headers:
      Authorization: "{{ secret('LINEAR_API_KEY') }}"
      Content-Type: "application/json"
      User-Agent: "Kestra-Linear-Triage-Sentinel/1.0"
    failOnGraphQLErrors: false
    query: |
      query GetUnassignedUrgentIssues {
        issues(filter: { team: { key: { eq: "{{ inputs.team_key }}" } }, priority: { eq: 1 }, assignee: { null: true }, state: { type: { nin: ["completed", "canceled"] } } }, first: {{ inputs.lookback_limit }}) {
          nodes {
            id
            identifier
            title
            url
            createdAt
            team {
              name
              key
            }
          }
        }
      }
    options:
      allowFailed: true

  - id: evaluate_unassigned_issues
    type: io.kestra.plugin.core.flow.If
    description: Check whether urgent unassigned issues are present in the triage queue.
    condition: "{{ outputs.fetch_urgent_unassigned_issues.body is defined and
      outputs.fetch_urgent_unassigned_issues.body.issues is defined and
      ((outputs.fetch_urgent_unassigned_issues.body.issues.nodes | length) > 0)
      }}"
    then:
      - id: alert_urgent_unassigned
        type: io.kestra.plugin.slack.notifications.SlackIncomingWebhook
        description: Dispatch high-priority Slack notification itemizing urgent
          unassigned issues to the on-call team.
        url: "{{ secret('SLACK_WEBHOOK_URL') }}"
        payload: |
          {
            "text": "🔥 *LINEAR INCIDENT TRIAGE: Urgent Unassigned Issues Detected* 🔥\n\n*Team:* `{{ inputs.team_key }}`\n*Pending Urgent Tickets:* {{ outputs.fetch_urgent_unassigned_issues.body.issues.nodes | length }}\n\n*Issues Requiring Immediate Owner Assignment:*\n{{ outputs.fetch_urgent_unassigned_issues.body.issues.nodes | jq('[.[] | \"• *\" + .identifier + \"*: \" + .title + \" - <\" + .url + \"|View Issue>\"] | join(\"\\n\")') | first }}\n\n*Execution ID:* {{ execution.id }}\n*Action Required:* On-call engineer please claim or assign tickets to avoid SLA violations."
          }

      - id: check_fail_policy
        type: io.kestra.plugin.core.flow.If
        description: Halt pipeline when fail_on_unassigned_urgent is enabled.
        condition: "{{ inputs.fail_on_unassigned_urgent }}"
        then:
          - id: halt_triage_gate
            type: io.kestra.plugin.core.execution.Fail
            description: Fail execution to trigger automated incident escalations.
    else:
      - id: log_triage_healthy
        type: io.kestra.plugin.core.log.Log
        description: Log clean operational status when zero urgent unassigned issues exist.
        message: "HEALTHY: Zero unassigned urgent issues detected in Linear team {{
          inputs.team_key }}."

  - id: log_audit_summary
    type: io.kestra.plugin.core.log.Log
    description: Record final audit metrics for triage velocity.
    message: "Linear triage sentinel completed for team {{ inputs.team_key }}.
      Unassigned urgent tickets count: {{
      outputs.fetch_urgent_unassigned_issues.body is defined and
      outputs.fetch_urgent_unassigned_issues.body.issues is defined ?
      (outputs.fetch_urgent_unassigned_issues.body.issues.nodes | length) : 0
      }}."

errors:
  - id: alert_on_linear_error
    type: io.kestra.plugin.slack.notifications.SlackIncomingWebhook
    description: Alert Engineering Operations if Linear GraphQL API returns errors
      or authentication fails.
    url: "{{ secret('SLACK_WEBHOOK_URL') }}"
    payload: |
      {
        "text": "⚠️ *Linear Triage Error*: Execution `{{ execution.id }}` failed to query team `{{ inputs.team_key }}`. Verify LINEAR_API_KEY validity."
      }

outputs:
  - id: status
    type: STRING
    value: "{{ outputs.fetch_urgent_unassigned_issues.body is defined and
      outputs.fetch_urgent_unassigned_issues.body.issues is defined and
      ((outputs.fetch_urgent_unassigned_issues.body.issues.nodes | length) > 0)
      ? 'URGENT_UNASSIGNED_DETECTED' : 'HEALTHY' }}"
  - id: unassigned_count
    type: INT
    value: "{{ outputs.fetch_urgent_unassigned_issues.body is defined and
      outputs.fetch_urgent_unassigned_issues.body.issues is defined ?
      (outputs.fetch_urgent_unassigned_issues.body.issues.nodes | length) : 0
      }}"