temporalio.contrib.google_adk_agents.GoogleAdkPlugin

class documentation

class GoogleAdkPlugin(SimplePlugin): (source)

Constructor: GoogleAdkPlugin(toolset_providers)

View In Hierarchy

A Temporal Worker Plugin configured for ADK.

Warning

This class is experimental and may change in future versions. Use with caution in production environments.

This plugin configures:

  • Pydantic Payload Converter (required for ADK objects).
  • Sandbox Passthrough for google.adk, google.genai, and OpenTelemetry modules.
  • ADK's time, id, and random providers, so ADK-generated ids and retry jitter come from the workflow's deterministic clock and a workflow-private deterministic random stream (see setup_deterministic_runtime).

At worker and replayer configuration time it also warns when the global OpenTelemetry meter or tracer provider is not replay-safe, since ADK telemetry recorded from workflow code would duplicate on replay.

Method __init__ Initializes the Temporal ADK Plugin.
Method configure_replayer See base class. Also warns when the global OpenTelemetry meter or tracer provider is not replay-safe, since every replayed workflow would re-emit ADK telemetry.
Method configure_worker See base class. Also warns when the global OpenTelemetry meter or tracer provider is not replay-safe, since ADK telemetry would duplicate on replay.
Method _configure_data_converter Undocumented

Inherited from SimplePlugin:

Method configure_client See base class.
Async Method connect_service_client See base class.
Method name See base class.
Async Method run_replayer See base class.
Async Method run_worker See base class.
Instance Variable activities Undocumented
Instance Variable data_converter Undocumented
Instance Variable interceptors Undocumented
Instance Variable nexus_service_handlers Undocumented
Instance Variable run_context Undocumented
Instance Variable workflow_failure_exception_types Undocumented
Instance Variable workflow_runner Undocumented
Instance Variable workflows Undocumented
Instance Variable _name Undocumented
def __init__(self, toolset_providers: list[TemporalMcpToolSetProvider | TemporalStatefulMcpToolSetProvider] | None = None): (source)
overrides temporalio.plugin.SimplePlugin.__init__

Initializes the Temporal ADK Plugin.

Parameters
toolset_providers:list[TemporalMcpToolSetProvider | TemporalStatefulMcpToolSetProvider] | NoneOptional list of stateless (TemporalMcpToolSetProvider) or stateful (TemporalStatefulMcpToolSetProvider) toolset providers for MCP integration.
def configure_replayer(self, config: ReplayerConfig) -> ReplayerConfig: (source)
overrides temporalio.plugin.SimplePlugin.configure_replayer

See base class. Also warns when the global OpenTelemetry meter or tracer provider is not replay-safe, since every replayed workflow would re-emit ADK telemetry.

def configure_worker(self, config: WorkerConfig) -> WorkerConfig: (source)
overrides temporalio.plugin.SimplePlugin.configure_worker

See base class. Also warns when the global OpenTelemetry meter or tracer provider is not replay-safe, since ADK telemetry would duplicate on replay.

def _configure_data_converter(self, converter: DataConverter | None) -> DataConverter: (source)

Undocumented