
PagerDuty PagerDutyAlert
CertifiedSend PagerDuty alert from errors task
PagerDuty PagerDutyAlert
Send PagerDuty alert from errors task
Posts a raw Events API v2 payload from an errors handler to PagerDuty. Provide the Events endpoint URL and JSON payload (including routing_key and event_action). Keep credentials in secrets; see PagerDuty documentation.
type: io.kestra.plugin.pagerduty.PagerDutyAlertExamples
Send a PagerDuty alert on a failed flow execution.
id: unreliable_flow
namespace: company.team
tasks:
- id: fail
type: io.kestra.plugin.scripts.shell.Commands
runner: PROCESS
commands:
- exit 1
errors:
- id: alert_on_failure
type: io.kestra.plugin.pagerduty.PagerDutyAlert
url: "{{ secret('PAGERDUTY_EVENT') }}" # https://events.pagerduty.com/v2/enqueue
payload: |
{
"dedup_key": "samplekey",
"routing_key": "samplekey",
"event_action": "trigger",
"payload" : {
"summary": "PagerDuty alert",
"source": "kestra",
"severity": "error"
}
}
Send a PagerDuty acknowledge from an errors handler.
id: pagerduty_acknowledge
namespace: company.team
tasks:
- id: do_work
type: io.kestra.plugin.scripts.shell.Commands
commands:
- exit 1
errors:
- id: acknowledge_existing_incident
type: io.kestra.plugin.pagerduty.PagerDutyAlert
url: "{{ secret('PAGERDUTY_EVENT') }}"
payload: |
{
"dedup_key": "existing-incident-key",
"routing_key": "samplekey",
"event_action": "acknowledge",
"payload": {
"summary": "Acknowledge incident from Kestra",
"source": "kestra",
"severity": "error"
}
}
Properties
url *string
1PagerDuty Events API URL
Endpoint such as https://events.pagerduty.com/v2/enqueue; store secrets with secret().
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150options
HTTP client options
Optional overrides for timeouts, charset, and headers when calling PagerDuty. Defaults: read timeout 10s, read idle 5m, pool idle 0s, max content 10MB, charset UTF-8.
io.kestra.plugin.pagerduty.AbstractPagerDutyConnection-RequestOptions
Connect timeout before fail
PT0SIdle connection pool timeout
UTF-8Default request charset
java.nio.charset.Charset
HTTP headers
HTTP headers to include in the request
10485760Maximum response size in bytes
PT5MIdle read timeout before close
PT10SRead timeout before fail
payload string
PagerDuty message payload
Raw JSON string sent to PagerDuty; must include routing_key and event_action. Supports templating.