Create or update a trigger.
Array of objects = 1 items |
List of created or updated triggers
from cognite.client.data_classes.workflows import WorkflowTriggerUpsert, WorkflowScheduledTriggerRule client.workflows.triggers.upsert( WorkflowTriggerUpsert( external_id="my_trigger", trigger_rule=WorkflowScheduledTriggerRule(cron_expression="0 0 * * *"), workflow_external_id="my_workflow", workflow_version="1", input={"a": 1, "b": 2}, metadata={"key": "value"}, ) ) from cognite.client.data_classes.workflows import WorkflowDataModelingTriggerRule, WorkflowTriggerDataModelingQuery from cognite.client.data_classes.data_modeling.query import NodeResultSetExpression, Select, SourceSelector from cognite.client.data_classes.data_modeling import ViewId from cognite.client.data_classes.filters import Equals view_id = ViewId("my_space_id", "view_external_id", "v1") client.workflows.triggers.upsert( WorkflowTriggerUpsert( external_id="my_trigger", trigger_rule=WorkflowDataModelingTriggerRule( data_modeling_query=WorkflowTriggerDataModelingQuery( with_={"timeseries": NodeResultSetExpression(filter=Equals(view_id.as_property_ref("name"), value="my_name"))}, select={"timeseries": Select([SourceSelector(view_id, ["name"])])}, ), batch_size=500, batch_timeout=300, ), workflow_external_id="my_workflow", workflow_version="1", ) )
{- "items": [
- {
- "externalId": "string",
- "triggerRule": {
- "triggerType": "schedule",
- "cronExpression": "string"
}, - "input": {
- "key1": "value1",
- "key2": "value2"
}, - "metadata": {
- "property1": "string",
- "property2": "string"
}, - "workflowExternalId": "string",
- "workflowVersion": "string",
- "createdTime": 1730204346000,
- "lastUpdatedTime": 1730204346000
}
]
}