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>",
        "timezone": "Europe/Oslo"
      },
      "input": {
        "key1": "value1",
        "key2": "value2"
      },
      "metadata": {},
      "workflowExternalId": "<string>",
      "workflowVersion": "<string>",
      "createdTime": 1730204346000,
      "lastUpdatedTime": 1730204346000,
      "isPaused": true
    }
  ]
}