airflow.providers.microsoft.azure.triggers.powerbi

Module Contents

Classes

PowerBITrigger

Triggers when Power BI dataset refresh is completed.
class airflow.providers.microsoft.azure.triggers.powerbi.PowerBITrigger(conn_id, dataset_id, group_id, timeout=60 * 60 * 24 * 7, proxies=None, api_version=None, check_interval=60, wait_for_termination=True)[source]

Bases: airflow.triggers.base.BaseTrigger

Triggers when Power BI dataset refresh is completed.

Wait for termination will always be True.

Parameters

  • conn_id (str) – The connection Id to connect to PowerBI.

  • timeout (float) – The HTTP timeout being used by the KiotaRequestAdapter (default is None). When no timeout is specified or set to None then there is no HTTP timeout on each request.

  • proxies (dict | None) – A dict defining the HTTP proxies to be used (default is None).

  • api_version (msgraph_core.APIVersion | None) – The API version of the Microsoft Graph API to be used (default is v1). You can pass an enum named APIVersion which has 2 possible members v1 and beta, or you can pass a string as v1.0 or beta.

  • dataset_id (str) – The dataset Id to refresh.

  • group_id (str) – The workspace Id where dataset is located.

  • end_time – Time in seconds when trigger should stop polling.

  • check_interval (int) – Time in seconds to wait between each poll.

  • wait_for_termination (bool) – Wait for the dataset refresh to complete or fail.

property conn_id: str[source]
property proxies: dict | None[source]
property api_version: msgraph_core.APIVersion[source]
serialize()[source]

Serialize the trigger instance.

async run()[source]

Make async connection to the PowerBI and polls for the dataset refresh status.

Was this entry helpful?