Airflow Summit 2026 is coming August 31 - September 2 in Austin, TX. Register now to secure your spot!

airflow.providers.openai.triggers.openai¶

Classes¶

OpenAIBatchTrigger

Triggers OpenAI Batch API.

Module Contents¶

class airflow.providers.openai.triggers.openai.OpenAIBatchTrigger(conn_id, batch_id, poll_interval, end_time)[source]¶

Bases: airflow.triggers.base.BaseTrigger

Triggers OpenAI Batch API.

conn_id[source]¶

poll_interval[source]¶

batch_id[source]¶

end_time[source]¶

serialize()[source]¶

Serialize OpenAIBatchTrigger arguments and class path.

async run()[source]¶

Make connection to OpenAI Client, and poll the status of batch.

Was this entry helpful?