airflow.providers.microsoft.azure.triggers.batch¶

Classes¶

AzureBatchTrigger

Trigger when Azure Batch job tasks reach a terminal state.

Module Contents¶

class airflow.providers.microsoft.azure.triggers.batch.AzureBatchTrigger(job_id, azure_batch_conn_id, end_time, poll_interval=30)[source]¶

Bases: airflow.triggers.base.BaseTrigger

Trigger when Azure Batch job tasks reach a terminal state.

Parameters:

job_id (str) – Azure Batch job identifier.
azure_batch_conn_id (str) – Azure Batch connection id.
end_time (float) – Absolute timeout deadline as determined using time.time().
poll_interval (int) – Poll interval in seconds.

job_id[source]¶

azure_batch_conn_id[source]¶

end_time[source]¶

poll_interval = 30[source]¶

serialize()[source]¶

Serialize trigger arguments and classpath.

async run()[source]¶

Poll Azure Batch job tasks until completion or timeout.