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?