airflow_fabric_run_item_operator_pipeline_notebook_example.py

1from datetime import datetime
2from airflow import DAG
3from airflow.providers.microsoft.fabric.operators.fabric import FabricRunItemOperator
4
5with DAG(
6    dag_id="example_fabric_operator",
7    start_date=datetime(2023, 8, 1),
8    schedule_interval=None,
9    catchup=False,
10) as dag:
11
12    # Task to run a Microsoft Fabric Item (e.g., a Pipeline or Notebook)
13    run_fabric_item = FabricRunItemOperator(
14        task_id="run_fabric_item",
15        workspace_id="your_workspace_id",
16        item_id="your_item_id",
17        fabric_conn_id="fabric_default",
18        wait_for_termination=True,
19        deferrable=True,
20    )
21
22    run_fabric_item