temporalio.contrib.openai_agents._openai_runner.TemporalOpenAIRunner

class documentation

class TemporalOpenAIRunner(AgentRunner): (source)

Constructor: TemporalOpenAIRunner(model_params)

View In Hierarchy

Temporal Runner for OpenAI agents.

Forwards model calls to a Temporal activity.

Method __init__ Initialize the Temporal OpenAI Runner.
Async Method run Run the agent in a Temporal workflow.
Method run_streamed Run the agent with streaming responses (not supported in Temporal workflows).
Method run_sync Run the agent synchronously (not supported in Temporal workflows).
Instance Variable model_params Undocumented
Instance Variable _runner Undocumented
def __init__(self, model_params: ModelActivityParameters): (source)

Initialize the Temporal OpenAI Runner.

async def run(self, starting_agent: Agent[TContext], input: str | list[TResponseInputItem], **kwargs) -> RunResult: (source)

Run the agent in a Temporal workflow.

def run_streamed(self, starting_agent: Agent[TContext], input: str | list[TResponseInputItem], **kwargs) -> RunResultStreaming: (source)

Run the agent with streaming responses (not supported in Temporal workflows).

def run_sync(self, starting_agent: Agent[TContext], input: str | list[TResponseInputItem], **kwargs) -> RunResult: (source)

Run the agent synchronously (not supported in Temporal workflows).

model_params = (source)

Undocumented

_runner = (source)

Undocumented