Azure CancelJob
CertifiedCancel an Azure Machine Learning job
Azure CancelJob
Cancel an Azure Machine Learning job
Requests cancellation of a running job. Cancellation is asynchronous in Azure ML: the job can sit in CANCEL_REQUESTED for minutes, so by default this task polls until the job actually reaches a terminal state before returning. Cancelling an already-terminal job is treated as a no-op, not a failure.
type: io.kestra.plugin.azure.ml.CancelJobExamples
id: azure_ml_cancel_job
namespace: company.team
inputs:
- id: job_name
type: STRING
tasks:
- id: cancel_job
type: io.kestra.plugin.azure.ml.CancelJob
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
jobName: "{{ inputs.job_name }}"
Properties
jobName *string
Job name
Name of the Azure Machine Learning job to cancel
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
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150checkFrequency
{
"maxDuration": "PT1H",
"interval": "PT10S"
}Polling frequency
Interval and max duration used when wait=true
io.kestra.plugin.azure.ml.SubmitCommandJob-CheckFrequency
PT10SPolling interval
Delay between status checks; defaults to PT10S. Azure ML jobs run for minutes to hours, so a tighter interval only adds needless ARM API calls
PT1HMax wait duration
Stop polling and fail after this duration; defaults to PT1H
clientId string
Client ID of the Azure AD application
Application (client) ID used for service principal authentication.
clientSecret string
Client secret for the Azure AD application
Secret value associated with the client ID; store in a Kestra secret.
pemCertificate string
PEM-encoded certificate content for client authentication
PEM text for certificate-based auth; alternative to clientSecret.
wait booleanstring
trueWait for the job to reach a terminal state
If true (default), polls until the job is actually cancelled instead of returning as soon as cancellation is requested
Outputs
jobName string
Job name
status string
NOT_STARTEDSTARTINGPROVISIONINGPREPARINGQUEUEDRUNNINGFINALIZINGCANCEL_REQUESTEDCOMPLETEDFAILEDCANCELEDNOT_RESPONDINGPAUSEDUNKNOWNJob status
Job status after the cancellation request
