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

Subscription ID

Azure subscription GUID that owns the Data Factory

Azure AD tenant ID (GUID)

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

Polling frequency

Interval and max duration used when wait=true

Definitions
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

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.

Factory name

Azure Data Factory name

Default{}

Pipeline parameters

Key/value parameters passed to the pipeline run

PEM-encoded certificate content for client authentication

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

Pipeline name

Pipeline to trigger inside the factory

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

Resource group name

Resource group containing the Data Factory

Defaulttrue

Wait for completion

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

Run ID

The ID of the pipeline run created in Azure Data Factory

Formaturi

Activities log URI

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

The total number of activities in the pipeline run.

The duration of the pipeline run in milliseconds.

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints