Azure GetJob
CertifiedGet Azure Stream Analytics job details
Azure GetJob
Get Azure Stream Analytics job details
Fetch the current state and metadata of an Azure Stream Analytics job. Use this task to poll job status in conditional flows, verify a job is running before triggering downstream tasks, or surface provisioning errors. Authenticates using an Azure AD service principal.
type: io.kestra.plugin.azure.streamanalytics.GetJobExamples
id: azure_stream_analytics_get_job
namespace: company.team
tasks:
- id: get_job
type: io.kestra.plugin.azure.streamanalytics.GetJob
subscriptionId: "{{ secret('AZURE_SUBSCRIPTION_ID') }}"
resourceGroup: my-resource-group
jobName: my-stream-analytics-job
tenantId: "{{ secret('AZURE_TENANT_ID') }}"
clientId: "{{ secret('AZURE_CLIENT_ID') }}"
clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
Properties
jobName *string
Job name
Name of the Stream Analytics job to retrieve
resourceGroup *string
Resource group name
Resource group containing the Stream Analytics job
subscriptionId *string
Subscription ID
Azure subscription GUID that owns the Stream Analytics job
tenantId *string
Azure AD tenant ID (GUID)
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
{}1150clientId 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.
Outputs
jobName string
Job name
Name of the Stream Analytics job
jobState string
Job state
Runtime state of the job. Possible values: Created, Starting, Running, Stopping, Stopped, Deleting, Failed, Degraded, Disabled, Scaling.
location string
Location
Azure region where the job is deployed
provisioningState string
Provisioning state
Provisioning state of the job. Possible values: Succeeded, Failed, Canceled, Provisioning, Deleting.
