Robert Phamle
04/25/2024, 5:02 PMMarvin
04/25/2024, 5:03 PMjson
{
"type": "compound",
"require": "all",
"within": 3600,
"triggers": [
{
"type": "event",
"posture": "Reactive",
"expect": ["event_name"]
},
// Additional triggers can be added here
]
}
Using the compound
trigger type, you specify that all included triggers must occur within a certain timeframe (here, one hour) for the automation to be executed.
You can learn more about setting up composite triggers in the Prefect documentation here: Automations.Robert Phamle
04/25/2024, 5:16 PM{
"type": "compound",
"require": "any",
"within": 10,
"triggers": [
{
"type": "event",
"match": {
"prefect.resource.id": "prefect.flow-run.*"
},
"match_related": {
"prefect.resource.role": "tag",
"prefect.resource.id": [
"prefect.tag.pagerduty_automation:pd-sq-sqprefect-tests-stage"
]
},
"after": [
"prefect.flow-run.Pending"
],
"expect": [
"prefect.flow-run.*"
],
"for_each": [
"prefect.resource.id"
],
"posture": "Proactive",
},
{
"type": "event",
"match": {
"prefect.resource.id": "prefect.flow-run.*"
},
"match_related": {
"prefect.resource.id": [
"prefect.tag.pagerduty_automation:pd-sq-sqprefect-tests-stage"
],
"prefect.resource.role": "tag"
},
"after": [],
"expect": [
"prefect.flow-run.Crashed",
"prefect.flow-run.TimedOut",
"prefect.flow-run.Failed"
],
"for_each": [
"prefect.resource.id"
],
"posture": "Reactive"
}
]
}
Marvin
04/25/2024, 5:16 PMdoes this look fine? i want this compound trigger to fire if either a flow run fails/crashes/times out or stays in pending for more than 15 minutes```{ "type": "compound", "require": "any", "within": 10, "triggers": [ { "type": "event", "match": { "prefect.resource.id": "prefect.flow-run.*" }, "match_related": { "prefect.resource.role": "tag", "prefect.resource.id": [ "prefect.tag.pagerduty_automation:pd-sq-sqprefect-tests-stage" ] }, "after": [ "prefect.flow-run.Pending" ], "expect": [ "prefect.flow-run.*" ], "for_each": [ "prefect.resource.id" ], "posture": "Proactive", }, { "type": "event", "match": { "prefect.resource.id": "prefect.flow-run.*" }, "match_related": { "prefect.resource.id": [ "prefect.tag.pagerduty_automation:pd-sq-sqprefect-tests-stage" ], "prefect.resource.role": "tag" }, "after": [], "expect": [ "prefect.flow-run.Crashed",