From 2e3cccfee698c07979ef98a78ba2c13e0e93d4b8 Mon Sep 17 00:00:00 2001 From: m-trieu Date: Tue, 11 Feb 2025 12:34:36 -0800 Subject: [PATCH 1/2] add endpoint type to WorkerMetadataResponse proto --- .../worker/windmill/src/main/proto/windmill.proto | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto b/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto index e1b52547fe73..53689a2f5cf7 100644 --- a/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto +++ b/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto @@ -926,6 +926,15 @@ message WorkerMetadataResponse { // Used to set gRPC authority. optional string external_endpoint = 5; + enum EndpointType { + UNKNOWN = 0; + CLOUDPATH = 1; + BORG = 2; + DIRECTPATH = 3; + } + + optional EndpointType endpoint_type = 6; + reserved 4; } From 7991a0915820fc5617328fa1f1f19ea0a28a6e86 Mon Sep 17 00:00:00 2001 From: m-trieu Date: Wed, 19 Feb 2025 09:25:12 -0800 Subject: [PATCH 2/2] add default value to endpoint_type --- .../worker/windmill/src/main/proto/windmill.proto | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto b/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto index 53689a2f5cf7..c58edab0fb47 100644 --- a/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto +++ b/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto @@ -933,7 +933,7 @@ message WorkerMetadataResponse { DIRECTPATH = 3; } - optional EndpointType endpoint_type = 6; + optional EndpointType endpoint_type = 6 [default = CLOUDPATH]; reserved 4; }