LineExecution

id: failure_alert_line
namespace: company.team

tasks:
  - id: send_line_alert
    type: io.kestra.plugin.line.LineExecution
    channelAccessToken: "{{ secret('LINE_CHANNEL_ACCESS_TOKEN') }}"
    executionId: "{{ trigger.executionId ?? 0 }}"
    customMessage: "Production workflow failed - immediate attention required!"
    customFields:
      Environment: "Production"
      Team: "DevOps"
      Priority: "High"

triggers:
  - id: failed_prod_workflows
    type: io.kestra.plugin.core.trigger.Flow
    conditions:
      - type: io.kestra.plugin.core.condition.ExecutionStatus
        in:
          - FAILED
          - WARNING
      - type: io.kestra.plugin.core.condition.ExecutionNamespace
        namespace: prod
        prefix: true

id: line_notification_with_custom_fields
namespace: company.team

tasks:
  - id: send_line_notification
    type: io.kestra.plugin.line.LineExecution
    channelAccessToken: "{{ secret('LINE_CHANNEL_ACCESS_TOKEN') }}"
    executionId: "{{ trigger.executionId ?? 0 }}"
    customMessage: "Data pipeline execution completed"
    customFields:
      Environment: "Production"
      Region: "Asia-Pacific"
      Duration: "{{ trigger.execution.duration ?? 0 }}"

triggers:
  - id: success_notifications
    type: io.kestra.plugin.core.trigger.Flow
    conditions:
      - type: io.kestra.plugin.core.condition.ExecutionStatus
        in:
          - SUCCESS