Azure CreateRun

Azure CreateRun
Certified
Start an Azure Data Factory pipeline run

Triggers a Data Factory pipeline and optionally waits for completion, emitting run metrics and writing activity logs to internal storage. Defaults: wait=true, polling interval=PT5S, timeout=PT1H; task fails on Failed/Cancelled pipeline states.

yaml
type: io.kestra.plugin.azure.datafactory.CreateRun

Examples

yaml
id: azure_datafactory_create_run
namespace: company.team

tasks:
  - id: create_run
    type: io.kestra.plugin.azure.datafactory.CreateRun
    factoryName: exampleFactoryName
    pipelineName: examplePipeline
    resourceGroupName: exampleResourceGroup
    subscriptionId: 12345678-1234-1234-12345678abc
    tenantId: "{{ secret('DATAFACTORY_TENANT_ID') }}"
    clientId: "{{ secret('DATAFACTORY_CLIENT_ID') }}"
    clientSecret: "{{ secret('DATAFACTORY_CLIENT_SECRET') }}"

Properties

subscriptionId *string

Subscription ID

Azure subscription GUID that owns the Data Factory

tenantId *string

Azure AD tenant ID (GUID)

checkFrequency

Default

{
  "maxDuration": "PT1H",
  "interval": "PT5S"
}

Polling frequency

Interval and max duration used when wait=true

Definitions

io.kestra.plugin.azure.datafactory.CreateRun-CheckFrequency

intervalstring

DefaultPT5S

Polling interval

Delay between status checks; defaults to PT5S

maxDurationstring

DefaultPT1H

Max 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.

factoryName string

Factory name

Azure Data Factory name

parameters object

Default{}

Pipeline parameters

Key/value parameters passed to the pipeline run

pemCertificate string

PEM-encoded certificate content for client authentication

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

pipelineName string

Pipeline name

Pipeline to trigger inside the factory

pluginDefaultsRef string

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

resourceGroupName string

Resource group name

Resource group containing the Data Factory

wait booleanstring

Defaulttrue

Wait for completion

If true (default), poll pipeline status and collect activity logs; false returns runId immediately

Outputs

runId string

Run ID

The ID of the pipeline run created in Azure Data Factory

uri string

Formaturi

Activities log URI

kestra:// URI for an Ion file containing activity runs with inputs/outputs when wait=true

Metrics

activities.count counter

The total number of activities in the pipeline run.

pipeline.duration.ms timer

The duration of the pipeline run in milliseconds.

Liquibase

Tasks that run Liquibase change management commands.

Data

OPA (Open Policy Agent)

Enterprise

Tasks to manage Open Policy Agent policies and decisions, including upload, evaluation, and partial evaluation.

Infrastructure

Azure CreateRunCertifiedStart an Azure Data Factory pipeline run

Azure CreateRun

More Plugins in this Category

Liquibase

OPA (Open Policy Agent)

Azure CreateRun
Certified
Start an Azure Data Factory pipeline run