contrib/google_adk_agents: stream LlmResponse chunks via Workflow Streams

[jssmith]

Summary

Adds a streaming integration to temporalio.contrib.google_adk_agents. The bridge honors stream=True and publishes raw LlmResponse chunks through a typed Workflow Streams topic handle, so a workflow can deliver token-level model output to clients while preserving durability.

• Opt in via the plugin's streaming_topic parameter. With no topic set, behavior is unchanged.
• Activity input is wrapped in StreamingInvokeInput (single dataclass per Temporal activity convention); the topic is required when streaming, since invoking streaming without publishing delivers no real-time value (the workflow only sees chunks batched at activity completion).

This was originally split out of PR #1423 (Workflow Streams library) and is now rebuilt as a single commit on top of merged main.

Test plan

• poe lint clean (ruff, pyright, mypy, basedpyright, pydocstyle)
• tests/contrib/google_adk_agents/test_adk_streaming.py — covers streaming chunk publishing and the typed topic contract
• Manual exercise via streaming-comparisons demos

🤖 Generated with Claude Code

[Copilot]

Pull request overview

Adds opt-in streaming support for temporalio.contrib.google_adk_agents by invoking ADK models with stream=True and publishing raw LlmResponse chunks to a Workflow Streams topic so external consumers can observe incremental output.

Changes:

• Introduces a new streaming activity (invoke_model_streaming) and an activity input wrapper (StreamingInvokeInput) to publish LlmResponse chunks via WorkflowStreamClient.
• Extends TemporalModel with streaming_topic / streaming_batch_interval and routes generate_content_async(stream=True) through the streaming activity.
• Adds integration tests validating chunk publishing and the “topic required for streaming” contract.

Reviewed changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 2 comments.

File	Description
temporalio/contrib/google_adk_agents/_model.py	Adds streaming activity + model options; publishes LlmResponse chunks to Workflow Streams when stream=True.
temporalio/contrib/google_adk_agents/_plugin.py	Registers the new streaming activity with the worker plugin.
tests/contrib/google_adk_agents/test_adk_streaming.py	New integration tests covering streaming publish behavior and required-topic failure mode.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.