Create or update triggers

Create or update a trigger.

Securityoidc-token or oauth2-client-credentials or oauth2-open-industrial-data or oauth2-auth-code
Request
Request Body schema: application/json
required
Array of objects = 1 items
Responses
200

List of created or updated triggers

post/workflows/triggers
Request samples
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",
    )
)
Response samples
application/json
{
  • "items": [
    • {
      }
    ]
}