airflow.providers.microsoft.azure.triggers.synapse¶

Classes¶

AzureSynapsePipelineTrigger

Trigger when an Azure Synapse pipeline run reaches a terminal state.

Module Contents¶

class airflow.providers.microsoft.azure.triggers.synapse.AzureSynapsePipelineTrigger(run_id, azure_synapse_conn_id, azure_synapse_workspace_dev_endpoint, end_time, check_interval=60)[source]¶

Bases: airflow.triggers.base.BaseTrigger

Trigger when an Azure Synapse pipeline run reaches a terminal state.

If an unexpected exception occurs while polling, the trigger attempts to cancel the pipeline run to avoid leaving orphaned executions.

Parameters:

run_id (str) – Pipeline run identifier.
azure_synapse_conn_id (str) – Azure Synapse connection id.
azure_synapse_workspace_dev_endpoint (str) – Synapse workspace dev endpoint.
end_time (float) – Epoch timestamp when the trigger should timeout.
check_interval (int) – Poll interval in seconds.

run_id[source]¶

azure_synapse_conn_id[source]¶

azure_synapse_workspace_dev_endpoint[source]¶

end_time[source]¶

check_interval = 60[source]¶

serialize()[source]¶

Serialize trigger arguments and classpath.

async run()[source]¶

Poll Synapse pipeline status until completion or timeout.