Azure GetJob

Azure GetJob

Certified

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.

yaml
type: io.kestra.plugin.azure.streamanalytics.GetJob
yaml
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

Job name

Name of the Stream Analytics job to retrieve

Resource group name

Resource group containing the Stream Analytics job

Subscription ID

Azure subscription GUID that owns the Stream Analytics job

Azure AD tenant ID (GUID)

Client ID of the Azure AD application

Application (client) ID used for service principal authentication.

Client secret for the Azure AD application

Secret value associated with the client ID; store in a Kestra secret.

PEM-encoded certificate content for client authentication

PEM text for certificate-based auth; alternative to clientSecret.

Reference (ref) of the pluginDefaults to apply to this task.

Job name

Name of the Stream Analytics job

Job state

Runtime state of the job. Possible values: Created, Starting, Running, Stopping, Stopped, Deleting, Failed, Degraded, Disabled, Scaling.

Location

Azure region where the job is deployed

Provisioning state

Provisioning state of the job. Possible values: Succeeded, Failed, Canceled, Provisioning, Deleting.

More Plugins in this Category

VMware (EE)
VMware
Enterprise

Tasks that automate VMware vSphere operations within Kestra workflows.

Infrastructure

33 tasks

3 blueprints

Canonical (EE)
Canonical
Enterprise

Tasks to interact with Canonical services, enabling automation and infrastructure management through API-driven workflows.

CloudInfrastructure

5 tasks