Daily pipeline digest to a QQ channel

id: tencent-qq-pipeline-digest
namespace: company.analytics

labels:
  team: analytics
  cadence: daily
  channel: qq

inputs:
  - id: team_label
    type: STRING
    defaults: Analytics Pipelines
    description: Friendly name of the team or pipeline group included in the digest header.

  - id: watched_namespace
    type: STRING
    defaults: company.analytics
    description: Namespace whose executions are counted for the digest.

  - id: digest_recipients
    type: ARRAY
    itemType: STRING
    defaults: [ "pipeline-digest-group" ]
    description: QQ group or user identifiers that should receive the daily digest.

variables:
  window_anchor: "{{ trigger.date ?? execution.startDate }}"
  window_start: "{{ (trigger.date ?? execution.startDate) | dateAdd(-1, 'DAYS') |
    date('yyyy-MM-dd') }}T00:00:00Z"
  window_end: "{{ (trigger.date ?? execution.startDate) | date('yyyy-MM-dd') }}T00:00:00Z"
  digest_date: "{{ (trigger.date ?? execution.startDate) | dateAdd(-1, 'DAYS') |
    date('yyyy-MM-dd') }}"

pluginDefaults:
  - type: io.kestra.plugin.kestra
    values:
      kestraUrl: "{{ secret('KESTRA_API_URL') }}"
      auth:
        username: "{{ secret('KESTRA_API_USERNAME') }}"
        password: "{{ secret('KESTRA_API_PASSWORD') }}"
  - type: io.kestra.plugin.tencent.qq
    values:
      url: "{{ secret('TENCENT_IM_URL') }}"
      token: "{{ secret('TENCENT_IM_TOKEN') }}"

tasks:
  - id: count_success
    type: io.kestra.plugin.kestra.executions.Count
    description: Counts executions that finished SUCCESS in the digest window.
    namespaces:
      - "{{ inputs.watched_namespace }}"
    states:
      - SUCCESS
    startDate: "{{ render(vars.window_start) }}"
    endDate: "{{ render(vars.window_end) }}"
    timeout: PT1M
    retry:
      type: constant
      interval: PT10S
      maxAttempt: 3

  - id: count_failed
    type: io.kestra.plugin.kestra.executions.Count
    description: Counts executions that ended FAILED in the digest window.
    namespaces:
      - "{{ inputs.watched_namespace }}"
    states:
      - FAILED
    startDate: "{{ render(vars.window_start) }}"
    endDate: "{{ render(vars.window_end) }}"
    timeout: PT1M
    retry:
      type: constant
      interval: PT10S
      maxAttempt: 3

  - id: count_warning
    type: io.kestra.plugin.kestra.executions.Count
    description: Counts executions that ended WARNING in the digest window.
    namespaces:
      - "{{ inputs.watched_namespace }}"
    states:
      - WARNING
    startDate: "{{ render(vars.window_start) }}"
    endDate: "{{ render(vars.window_end) }}"
    timeout: PT1M
    retry:
      type: constant
      interval: PT10S
      maxAttempt: 3

  - id: count_running
    type: io.kestra.plugin.kestra.executions.Count
    description: Counts executions still RUNNING at digest time.
    namespaces:
      - "{{ inputs.watched_namespace }}"
    states:
      - RUNNING
    startDate: "{{ render(vars.window_start) }}"
    endDate: "{{ render(vars.window_end) }}"
    timeout: PT1M
    retry:
      type: constant
      interval: PT10S
      maxAttempt: 3

  - id: build_summary
    type: io.kestra.plugin.core.debug.Return
    description: Assembles the digest body text from the real execution counts.
    format: |
      Daily pipeline digest for {{ inputs.team_label }} ({{ inputs.watched_namespace }}) on {{ render(vars.digest_date) }}.
      Window: {{ render(vars.window_start) }} to {{ render(vars.window_end) }}.
      Success: {{ outputs.count_success.count }} | Failed: {{ outputs.count_failed.count }} | Warning: {{ outputs.count_warning.count }} | Running: {{ outputs.count_running.count }}.
      {% if outputs.count_failed.count > 0 %}Action needed: review the {{ outputs.count_failed.count }} failed execution(s) in the Kestra UI.{% else %}No failures in the window.{% endif %}

  - id: log_counts
    type: io.kestra.plugin.core.log.Log
    description: Surfaces the counts in the run logs for operators.
    message: "{{ render(outputs.build_summary.value) }}"

  - id: post_digest_to_qq
    type: io.kestra.plugin.tencent.qq.QQIncomingWebhook
    description: Posts the assembled daily pipeline digest to the team QQ channel.
    timeout: PT30S
    retry:
      type: constant
      interval: PT10S
      maxAttempt: 3
    payload: |
      {
        "To_Account": {{ inputs.digest_recipients | toJson }},
        "MsgType": "TIMTextElem",
        "MsgContent": {
          "Text": {{ outputs.build_summary.value | toJson }}
        }
      }

triggers:
  - id: daily_morning_digest
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "0 8 * * *"
    timezone: Asia/Shanghai

errors:
  - id: alert_digest_failure
    type: io.kestra.plugin.tencent.qq.QQIncomingWebhook
    description: Notifies the channel if the digest itself could not be produced or
      delivered.
    timeout: PT30S
    retry:
      type: constant
      interval: PT10S
      maxAttempt: 3
    payload: |
      {
        "To_Account": {{ inputs.digest_recipients | toJson }},
        "MsgType": "TIMTextElem",
        "MsgContent": {
          "Text": {{ ("Pipeline digest for " ~ inputs.team_label ~ " failed to run (execution " ~ execution.id ~ "). Check the Kestra execution for details.") | toJson }}
        }
      }