feat(interactions): add automaticContinuation to Interactions.create in the Java SDK

Foreground `Interactions.create()` calls are capped per request by the server (32k output tokens unary, 64k streaming) and stop with `status="requires_continuation"` plus a `continuation_token`. `Interactions.create`, `AsyncInteractions.create`, `CreateInteractionRequest`, and `CreateInteractionRequestBuilder` now support `automaticContinuation` (default `true`) and chain continuation hops client-side so a plain `create()` returns the full decode.

Request chaining:
- Each hop after the first sends the `continuation_token` from the previous hop. With `store` enabled (default) it sets `previous_interaction_id` to the hop that issued the token and omits `input`; with `store=false` it resends the original `input`.
- Unary foreground model calls default `generation_config.max_output_tokens` to 65536 when unset without mutating caller request objects (streaming uses the server's 64k default). Explicit values are never overridden.
- Stops on `completed`, `incomplete` (token preserved for manual resumption), `requires_action`, `failed`, `cancelled`, a missing token, or a repeated token. Skipped for `CreateAgentInteraction` requests and `background=true`; `background=true` with `automaticContinuation=false` throws `IllegalArgumentException`.

Unary (`stream=false`) merging:
- Hops are merged into one `Interaction`: `steps` concatenated in hop order (leading `user_input` steps dropped on later hops), `usage` counts and per-modality breakdowns summed across hops with `usage.initialInputTokens` taken from hop 1, `id` / `status` / `continuationToken` / `updated` from the final hop, and `previousInteractionId` / `created` / `input` from hop 1.
- `continuationIds` lists every hop id in order, de-duplicated with any server-provided ids. Output convenience helpers (`outputText`, etc.) are recomputed across hop boundaries.

Streaming (`stream=true`):
- Events from all hops are yielded verbatim via `ContinuationEventStream` (sync and async). Consumers should treat `interaction.completed` with `status="requires_continuation"` as intermediate.
- Mid-hop transport drops (`IOException` / `UncheckedIOException`) or premature EOF resume from the latest `interaction.status_update` checkpoint token when no content was yielded since that checkpoint (up to 3 no-progress reconnects). SSE `error` events are terminal; HTTP status retries stay with `RetryConfig`.

Timeouts and errors:
- Per-call `timeout(Duration)` on `CreateInteractionRequest` / builders bounds the whole `create()` call across hops via `CallDeadline`, while client-level `HttpOptions.timeout` and `RetryConfig` apply per hop.
- A failure or timeout after progress throws `ContinuationInterruptedException` (`getCause()` chained) carrying `partialInteraction()`, `continuationToken()`, `interactionId()`, and `continuationIds()` so billed work is preserved for manual resumption. First-hop failures propagate unchanged.

Opt-out:
- `automaticContinuation=false` returns the single server response untouched (no budget injection, no merging) and logs a one-time `WARNING` if it stops at `requires_continuation` without a caller-supplied `continuation_token`.

Tests: `InteractionContinuationConformanceTest` (52 sync + 28 async streaming conformance cases) and `InteractionContinuationTest` (whole-call timeout, builder immutability, and warning tests).
PiperOrigin-RevId: 995657095

Author: MarkDaoust

google/genai/_gaos/google_genai.py

@@ -48,6 +48,7 @@ def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> Union[interactions.Interaction, Stream[interactions.InteractionSSEEvent]]:
         r"""Creates a new interaction.
 
@@ -87,6 +88,7 @@ def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> interactions.Interaction:
         r"""Creates a new interaction.
 
@@ -154,6 +156,7 @@ def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> Stream[interactions.InteractionSSEEvent]:
         r"""Creates a new interaction.
 
@@ -220,6 +223,7 @@ def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> interactions.Interaction:
         r"""Creates a new interaction.
 
@@ -285,6 +289,7 @@ def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> Stream[interactions.InteractionSSEEvent]:
         r"""Creates a new interaction.
 
@@ -335,6 +340,7 @@ def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
         **body_kwargs: Any,
     ) -> Union[interactions.Interaction, Stream[interactions.InteractionSSEEvent]]:
         r"""Creates a new interaction.
@@ -1317,6 +1323,7 @@ async def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> Union[interactions.Interaction, AsyncStream[interactions.InteractionSSEEvent]]:
         r"""Creates a new interaction.
 
@@ -1356,6 +1363,7 @@ async def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> interactions.Interaction:
         r"""Creates a new interaction.
 
@@ -1423,6 +1431,7 @@ async def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> AsyncStream[interactions.InteractionSSEEvent]:
         r"""Creates a new interaction.
 
@@ -1489,6 +1498,7 @@ async def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> interactions.Interaction:
         r"""Creates a new interaction.
 
@@ -1554,6 +1564,7 @@ async def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
     ) -> AsyncStream[interactions.InteractionSSEEvent]:
         r"""Creates a new interaction.
 
@@ -1604,6 +1615,7 @@ async def create(
         extra_query: Optional[Mapping[str, Any]] = None,
         extra_body: Optional[Mapping[str, Any]] = None,
         timeout: Optional[Union[float, httpx.Timeout]] = None,
+        automatic_continuation: Optional[bool] = None,
         **body_kwargs: Any,
     ) -> Union[interactions.Interaction, AsyncStream[interactions.InteractionSSEEvent]]:
         r"""Creates a new interaction.

google/genai/_gaos/interactions.py

@@ -167,6 +167,11 @@ class InteractionTypedDict(TypedDict):
     r"""Configuration parameters for the agent interaction."""
     cached_content: NotRequired[str]
     r"""The name of the cached content used as context to serve the prediction. Note: only used in explicit caching, where users can have control over caching (e.g. what content to cache) and enjoy guaranteed cost savings. Format: cachedContents/{cachedContent}"""
+    continuation_ids: NotRequired[List[str]]
+    r"""The IDs of all server interactions merged into this response when automatic continuation is enabled, in order (ending with the final hop's ID).
+
+    Note: this is added by the SDK.
+    """
     continuation_token: NotRequired[str]
     r"""Opaque token to resume a long decode. Output: set when status is
     REQUIRES_CONTINUATION and decoding can be resumed. Input: pass the latest
@@ -263,6 +268,12 @@ class Interaction(BaseModel):
     ] = None
     r"""The name of the cached content used as context to serve the prediction. Note: only used in explicit caching, where users can have control over caching (e.g. what content to cache) and enjoy guaranteed cost savings. Format: cachedContents/{cachedContent}"""
 
+    continuation_ids: Optional[List[str]] = None
+    r"""The IDs of all server interactions merged into this response when automatic continuation is enabled, in order (ending with the final hop's ID).
+
+    Note: this is added by the SDK.
+    """
+
     continuation_token: Optional[str] = None
     r"""Opaque token to resume a long decode. Output: set when status is
     REQUIRES_CONTINUATION and decoding can be resumed. Input: pass the latest
@@ -380,6 +391,7 @@ def _serialize_model(self, handler):
                 "agent",
                 "agent_config",
                 "cached_content",
+                "continuation_ids",
                 "continuation_token",
                 "created",
                 "environment",