temporalio.contrib.strands._model_activity.ModelActivity

class documentation

class ModelActivity: (source)

Constructor: ModelActivity(factories, default_name)

View In Hierarchy

Holds the registered model factories and exposes the model activities.

Method __init__ Store the factories; models are constructed lazily on first use.
Async Method invoke_model Run the named model and return its stream events as a list.
Async Method invoke_model_streaming Run the named model and publish each stream event to a WorkflowStream.
Method _get_model Undocumented
Instance Variable _default_name Undocumented
Instance Variable _factories Undocumented
Instance Variable _models Undocumented
def __init__(self, factories: dict[str, Callable[[], Model]], *, default_name: str | None = None): (source)

Store the factories; models are constructed lazily on first use.

default_name is set only by the plugin's own auto-registered BedrockModel default. User-supplied models leave it None, which forces every TemporalAgent to specify model= explicitly.

async def invoke_model(self, input: _InvokeModelInput) -> list[StreamEvent]: (source)

Run the named model and return its stream events as a list.

async def invoke_model_streaming(self, input: _StreamingInvokeModelInput) -> list[StreamEvent]: (source)

Run the named model and publish each stream event to a WorkflowStream.

def _get_model(self, name: str | None) -> Model: (source)

Undocumented

_default_name = (source)

Undocumented

_factories = (source)

Undocumented

_models: dict[str, Model] = (source)

Undocumented