Azure NewModelVersionTrigger

Azure NewModelVersionTrigger
Certified
Trigger a flow when a new Azure Machine Learning model version is registered

Polls a model's latest version on a schedule and starts an execution when a new version is detected. The last-seen version is persisted in the flow's namespace KV Store so the trigger does not re-fire for a version it already delivered. Only the latest version at each poll is compared against the last-seen one: if several versions are registered between two polls, only the latest of them fires and the intermediate ones are not individually delivered — the same interval-bound characteristic as every other stateful polling trigger in this plugin.

yaml
type: io.kestra.plugin.azure.ml.NewModelVersionTrigger

Examples

Trigger a flow whenever a new version of a model is registered.

yaml
id: react_to_new_model_version
namespace: company.team

tasks:
  - id: log
    type: io.kestra.plugin.core.log.Log
    message: "New model version: {{ trigger.version }} at {{ trigger.modelUri }}"

triggers:
  - id: watch
    type: io.kestra.plugin.azure.ml.NewModelVersionTrigger
    interval: PT5M
    tenantId: "{{ secret('AZURE_TENANT_ID') }}"
    clientId: "{{ secret('AZURE_CLIENT_ID') }}"
    clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
    subscriptionId: "{{ secret('AZURE_SUBSCRIPTION_ID') }}"
    resourceGroupName: ml-rg
    workspaceName: ml-workspace
    modelName: fraud-detector

Properties

modelName *string

Model name

Name of the model to watch for new versions

resourceGroupName *string

Resource group name

Resource group containing the Machine Learning workspace

subscriptionId *string

Subscription ID

Azure subscription GUID that owns the Machine Learning workspace

tenantId *string

Azure AD tenant ID (GUID)

workspaceName *string

Workspace name

Name of the Azure Machine Learning workspace

allowConcurrent boolean

Defaultfalse

Specifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.

clientId string

Client ID of the Azure AD application

clientSecret string

Client secret for the Azure AD application

interval string

DefaultPT5M

Formatduration

Interval between polling.

The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.

on string

DefaultCREATE_OR_UPDATE

Possible Values

CREATEUPDATECREATE_OR_UPDATE

Trigger event type

Defines when the trigger fires.

CREATE: only for newly discovered entities.
UPDATE: only when an already-seen entity changes.
CREATE_OR_UPDATE: fires on either event.

pemCertificate string

PEM-encoded certificate content for client authentication

stateKey string

State key

Custom key used to store the last-seen model version.

stateTtl string

State TTL

How long the last-seen model version state is retained.

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

when string

Defaulttrue

A condition that determines whether the trigger should run.

A Pebble expression evaluated at trigger time. The trigger fires only when the expression evaluates to a truthy value (true, a non-empty string, a non-zero number). Use this to gate trigger execution on dynamic runtime values such as execution labels, flow variables, or environment conditions.

Outputs

modelName string

Model name

modelUri string

Formaturi

Model URI

Storage URI backing this model version

version string

Model version

Newly detected model version