Sonilo Generation Health Gate

id: sonilo-generation-health-gate
namespace: company.team
description: |
  Submit a music generation job to the Sonilo API on a schedule, wait
  for it to finish, classify the returned status as COMPLETED,
  FAILED, UNKNOWN, or UNREACHABLE, log clean generations, and alert
  Slack the moment a job fails or the API cannot be reached.

inputs:
  - id: music_prompt
    type: STRING
    defaults: "Warm analog synths under a quiet piano"
    displayName: "Music Prompt"
    description: "Text prompt describing the music to generate, up to Sonilo's
      documented 2000-character practical limit."
  - id: generation_duration_seconds
    type: INT
    defaults: 30
    displayName: "Duration (Seconds)"
    description: "Requested length of the generated audio, 5 to 360 seconds."
  - id: output_format
    type: SELECT
    defaults: "wav"
    values:
      - "m4a"
      - "wav"
      - "mp3"
    displayName: "Output Format"
    description: "Audio container for the generated file. wav and mp3 require
      Sonilo's async mode, which the task selects automatically."

triggers:
  - id: sonilo_health_gate_schedule
    type: io.kestra.plugin.core.trigger.Schedule
    description: "Run a canary generation and classify its health every 6 hours."
    cron: "0 */6 * * *"
    disabled: true
    inputs:
      music_prompt: "Warm analog synths under a quiet piano"
      generation_duration_seconds: 30
      output_format: "wav"

tasks:
  - id: generate_music
    type: io.kestra.plugin.sonilo.GenerateMusicFromText
    description: "Submit a text-to-music generation job to Sonilo and wait for it to
      reach a terminal state (wav/mp3 output forces async mode with internal
      polling)."
    apiToken: "{{ secret('SONILO_API_TOKEN') }}"
    prompt: "{{ inputs.music_prompt }}"
    duration: "{{ inputs.generation_duration_seconds }}"
    outputFormat: "{{ inputs.output_format }}"
    allowFailure: true

  - id: classify_generation_status
    type: io.kestra.plugin.core.debug.Return
    description: "Classify UNREACHABLE when no status was returned, COMPLETED when
      status is succeeded/completed/success, FAILED when status is
      failed/canceled/cancelled/error, otherwise UNKNOWN. These are Sonilo's own
      normalized terminal status values."
    format: "{{ outputs.generate_music.status is defined ?
      ((outputs.generate_music.status == 'succeeded' or
      outputs.generate_music.status == 'completed' or
      outputs.generate_music.status == 'success') ? 'COMPLETED' :
      ((outputs.generate_music.status == 'failed' or
      outputs.generate_music.status == 'canceled' or
      outputs.generate_music.status == 'cancelled' or
      outputs.generate_music.status == 'error') ? 'FAILED' : 'UNKNOWN')) :
      'UNREACHABLE' }}"

  - id: route_by_generation_status
    type: io.kestra.plugin.core.flow.Switch
    description: "Log a quiet confirmation when generation completed, page Slack
      when it failed, or page Slack when the API could not be reached."
    value: "{{ outputs.classify_generation_status.value }}"
    cases:
      "COMPLETED":
        - id: log_completed
          type: io.kestra.plugin.core.log.Log
          message: "Sonilo generation completed, task {{ outputs.generate_music.taskId }},
            status {{ outputs.generate_music.status }}."
      "FAILED":
        - id: alert_failed
          type: io.kestra.plugin.slack.notifications.SlackIncomingWebhook
          url: "{{ secret('SLACK_WEBHOOK_URL') }}"
          payload: |
            {
              "text": "Sonilo sentinel FAILED: generation task {{ outputs.generate_music.taskId }} ended with status {{ outputs.generate_music.status }} for prompt \"{{ inputs.music_prompt }}\". Execution {{ execution.id }}."
            }
      "UNREACHABLE":
        - id: alert_unreachable
          type: io.kestra.plugin.slack.notifications.SlackIncomingWebhook
          url: "{{ secret('SLACK_WEBHOOK_URL') }}"
          payload: |
            {
              "text": "Sonilo sentinel UNREACHABLE: no status was returned for the canary generation (invalid API token, platform outage, or wait timed out). Execution {{ execution.id }}."
            }
    defaults:
      - id: log_unknown_status
        type: io.kestra.plugin.core.log.Log
        message: "Completed Sonilo health check with an unrecognized status: {{
          outputs.generate_music.status }}"

  - id: log_audit_status
    type: io.kestra.plugin.core.log.Log
    description: "Post-audit status line recorded on every run regardless of branch,
      for a continuous generation-health trend in the execution history."
    message: "Sonilo health audit: prompt={{ inputs.music_prompt }}, format={{
      inputs.output_format }}, taskId={{ outputs.generate_music.taskId }},
      status={{ outputs.classify_generation_status.value }}, execution={{
      execution.id }}."

errors:
  - id: alert_flow_failure
    type: io.kestra.plugin.slack.notifications.SlackIncomingWebhook
    description: "Alert Slack when the health gate flow itself fails, so a broken
      check never silently stops monitoring Sonilo generation health."
    url: "{{ secret('SLACK_WEBHOOK_URL') }}"
    payload: |
      {
        "text": "Sonilo generation health gate flow {{ flow.id }} FAILED (execution {{ execution.id }}). Generation health is now unknown; check the task logs and the Sonilo API manually."
      }

outputs:
  - id: status
    type: STRING
    value: "{{ outputs.classify_generation_status.value }}"