Microsoft Fabric RunPipeline

Microsoft Fabric RunPipeline
Certified
Run a Microsoft Fabric Data Pipeline

Triggers a Fabric Data Pipeline job and optionally waits for completion. Posts to the Fabric scheduler API with jobType=Pipeline, polls the returned job instance URL, and fails if the pipeline ends in Failed, Cancelled, or Deduped state. Defaults: wait=true, pollFrequency=PT5S, timeout=PT1H.

yaml
type: io.kestra.plugin.microsoft.fabric.data.engineering.RunPipeline

Examples

yaml
id: fabric_pipeline_run
namespace: company.team

tasks:
  - id: run_pipeline
    type: io.kestra.plugin.microsoft.fabric.data.engineering.RunPipeline
    tenantId: "{{ secret('FABRIC_TENANT_ID') }}"
    clientId: "{{ secret('FABRIC_CLIENT_ID') }}"
    clientSecret: "{{ secret('FABRIC_CLIENT_SECRET') }}"
    workspaceId: "your-workspace-id"
    pipelineId: "your-pipeline-id"
    parameters:
      myParam: "myValue"

Properties

pipelineId *string

Pipeline ID

Microsoft Fabric Data Pipeline item GUID

workspaceId *string

Workspace ID

Microsoft Fabric workspace GUID

clientId string

Client ID

Service principal client (application) ID

clientSecret string

Client Secret

Service principal client secret. When both clientId and clientSecret are provided, service principal authentication is used; otherwise DefaultAzureCredential is used.

parameters object

Default{}

Pipeline parameters

Key/value parameters passed to the pipeline execution

pluginDefaultsRef string

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

pollFrequency string

DefaultPT5S

Poll frequency

Interval between status checks when wait=true

tenantId string

Tenant ID

Azure Active Directory tenant ID for authentication

timeout string

DefaultPT1H

Timeout

Maximum time to wait for completion; throws TimeoutException when exceeded

wait booleanstring

Defaulttrue

Wait for completion

Poll until the pipeline job reaches a terminal state; returns runId immediately when false

Outputs

runId string

Job instance ID

Unique ID of the pipeline job instance

status string

Final status

Terminal status of the pipeline job: Completed, Failed, Cancelled, or Deduped

Clickhouse

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

Data

Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

Microsoft Fabric RunPipelineCertifiedRun a Microsoft Fabric Data Pipeline

Microsoft Fabric RunPipeline

More Plugins in this Category

Clickhouse

Weaviate

Microsoft Fabric RunPipeline
Certified
Run a Microsoft Fabric Data Pipeline