temporalio / sdk-java / #388

68%

master: 75%

Build Type

push

github

Committed by web-flow

Commit Message

Add Google Cloud Run CloudRunIdPlugin (#3028)

* Add Google Cloud Run worker identity/deployment helper

Adds an experimental Google Cloud Run helper, mirroring the existing AWS
Lambda module's worker-ID behavior. Because Cloud Run runs a long-lived
container (unlike Lambda's per-invocation model), this is a metadata
helper rather than a worker wrapper: it reads the Cloud Run instance
metadata -- the instance id from the metadata server, plus the worker
pool/service name and revision from CLOUD_RUN_WORKER_POOL / CLOUD_RUN_REVISION
(worker pools) or K_SERVICE / K_REVISION (services) -- and derives a worker
identity and a WorkerDeploymentVersion to apply to a normal long-lived
worker. Covers both Cloud Run worker pools and services.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

* Set worker versioning behavior to PINNED in the Cloud Run worker apply

The worker-side apply helper enabled versioning and set the deployment
version but left the default versioning behavior unset, so a versioned
worker with a plain (un-annotated) workflow failed to register. Default it
to PINNED; a per-workflow versioning behavior still takes precedence.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

* Add unit tests for GoogleCloudRunMetadata

Cover the Cloud Run metadata helper: environment-variable precedence
(CLOUD_RUN_WORKER_POOL over K_SERVICE, CLOUD_RUN_REVISION over
K_REVISION), worker identity fallbacks, WorkerDeploymentVersion mapping
and its empty name/revision error, the metadata HTTP request
(Metadata-Flavor: Google header, body trimming, non-200 and unreachable
errors), and the applyTo(...) methods (client identity, and PINNED
worker deployment versioning).

The metadata request is served by an in-process com.sun.net.httpserver
HttpServer and the environment lookup is injected through a new
package-private fetch(String, Duration, Function) test seam, so the
tests touch neither the network nor the real process environment. The
seam is not p... (continued)

Coverage Stats

7836 of 13628 branches covered (57.5%)

Branch coverage included in aggregate %.

0 of 71 new or added lines in 2 files covered. (0.0%)

17 existing lines in 7 files now uncovered.

31829 of 44485 relevant lines covered (71.55%)

0.72 hits per line