Triggers allow you to automate the execution of your data workflows based on specific conditions, such as scheduled times (defined by cron expressions).
Required capabilities:
workflowOrchestrationACL:READ
List all triggers. The results are sorted by externalId in ascending order.
List of triggers
{- "items": [
- {
- "externalId": "string",
- "triggerRule": {
- "triggerType": "schedule",
- "cronExpression": "string",
- "timezone": "Europe/Oslo"
}, - "input": {
- "key1": "value1",
- "key2": "value2"
}, - "metadata": {
- "property1": "string",
- "property2": "string"
}, - "workflowExternalId": "string",
- "workflowVersion": "string",
- "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000,
- "isPaused": true
}
], - "nextCursor": "4zj0Vy2fo0NtNMb229mI9r1V3YG5NBL752kQz1cKtwo"
}Required capabilities:
workflowOrchestrationACL:WRITE
Create or update a trigger.
Array of objects = 1 items |
List of created or updated triggers
{- "items": [
- {
- "externalId": "string",
- "triggerRule": {
- "triggerType": "schedule",
- "cronExpression": "string",
- "timezone": "Europe/Oslo"
}, - "input": {
- "key1": "value1",
- "key2": "value2"
}, - "metadata": {
- "property1": "string",
- "property2": "string"
}, - "workflowExternalId": "string",
- "workflowVersion": "string",
- "authentication": {
- "nonce": "hOfy4Zop4N2SPRfl"
}
}
]
}{- "items": [
- {
- "externalId": "string",
- "triggerRule": {
- "triggerType": "schedule",
- "cronExpression": "string",
- "timezone": "Europe/Oslo"
}, - "input": {
- "key1": "value1",
- "key2": "value2"
}, - "metadata": {
- "property1": "string",
- "property2": "string"
}, - "workflowExternalId": "string",
- "workflowVersion": "string",
- "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000,
- "isPaused": true
}
]
}Required capabilities:
workflowOrchestrationACL:WRITE
Delete a trigger.
Array of objects = 1 items |
Empty response.
{- "items": [
- {
- "externalId": "string"
}
]
}{ }Required capabilities:
workflowOrchestrationACL:READ
Get information about every run of a trigger. This includes timing information and a reference to the started execution (or an explanation as to why it failed). The returned items are sorted by fireTime in descending order (newest first), followed by externalId in ascending order.
A list of runs of the trigger
The response for a failed request.
res = client.workflows.triggers.list_runs("my_trigger", limit=None)
{- "items": [
- {
- "fireTime": 0,
- "externalId": "string",
- "workflowExternalId": "string",
- "workflowVersion": "string",
- "workflowExecutionId": "059edaa4-a17a-4102-910e-2c3591500cce",
- "status": "success",
- "reasonForFailure": "string"
}
]
}Required capabilities:
workflowOrchestrationACL:WRITE
Pauses a trigger. When paused, the trigger will not fire until it is resumed. Note: For data modeling and records stream triggers, processing continues where the last trigger run left off at pause time, not necessarily starting again on the freshest data. The cursor can become invalid if paused too long (stream retention applies).
Empty response.
The trigger was not found
{ }Required capabilities:
workflowOrchestrationACL:WRITE
Resumes a trigger. Once resumed, the trigger will fire according to its configuration. Note: For data modelling and records stream triggers, processing continues where the last trigger run left off at pause time, not necessarily starting again on the freshest data. The cursor can become invalid if paused too long (stream retention applies).
Empty response.
The trigger was not found
{ }