airflow.providers.openai.triggers.agent

Classes

OpenAIAgentSessionTrigger

Wait for the first turn of an exclusively owned Managed Agents session.

Module Contents

class airflow.providers.openai.triggers.agent.OpenAIAgentSessionTrigger(conn_id, session_id, poll_interval, end_time)[source]

Bases: airflow.triggers.base.BaseTrigger

Wait for the first turn of an exclusively owned Managed Agents session.

Parameters:

  • conn_id (str) – OpenAI connection ID.

  • session_id (str) – Fresh session whose first turn is being awaited.

  • poll_interval (float) – Seconds between polls.

  • end_time (float) – Epoch deadline, preserved across triggerer restarts.

conn_id[source]
session_id[source]
poll_interval[source]
end_time[source]
serialize()[source]

Serialize identifiers and the absolute deadline, without credentials.

async run()[source]

Poll off the event loop and emit one terminal result.

async on_kill()[source]

Cancel a killed deferred task’s turn on Airflow versions supporting trigger cleanup.

Was this entry helpful?