Report poller target on poll requests and in the worker heartbeat

openapi/openapiv2.json

@@ -21622,6 +21622,11 @@
         "isAutoscaling": {
           "type": "boolean",
           "title": "Set true if the number of concurrent pollers is auto-scaled"
+        },
+        "pollerTarget": {
+          "type": "integer",
+          "format": "int32",
+          "description": "Number of pollers this poller pool is currently targeting, which may differ from current_pollers.\n0 if unknown, such as a poller pool of fixed size."
         }
       }
     },

openapi/openapiv3.yaml

@@ -20056,6 +20056,12 @@ components:
         isAutoscaling:
           type: boolean
           description: Set true if the number of concurrent pollers is auto-scaled
+        pollerTarget:
+          type: integer
+          description: |-
+            Number of pollers this poller pool is currently targeting, which may differ from current_pollers.
+             0 if unknown, such as a poller pool of fixed size.
+          format: int32
     WorkerSelector:
       type: object
       properties:

temporal/api/taskqueue/v1/message.proto

@@ -33,6 +33,13 @@ message TaskQueueMetadata {
     google.protobuf.DoubleValue max_tasks_per_second = 1;
 }
 
+// Worker-reported state about the poller pool issuing a poll.
+message PollerScalingInfo {
+    // Number of pollers this worker is targeting for this task queue and task type.
+    // 0 if unknown, such as a poller pool of fixed size.
+    int32 poller_target = 1;
+}
+
 message TaskQueueVersioningInfo {
     // Specifies which Deployment Version should receive new workflow executions and tasks of
     // existing unversioned or AutoUpgrade workflows.

temporal/api/worker/v1/message.proto

@@ -22,6 +22,10 @@ message WorkerPollerInfo {
 
   // Set true if the number of concurrent pollers is auto-scaled
   bool is_autoscaling = 3;
+
+  // Number of pollers this poller pool is currently targeting, which may differ from current_pollers.
+  // 0 if unknown, such as a poller pool of fixed size.
+  int32 poller_target = 4;
 }
 
 message WorkerSlotsInfo {

temporal/api/workflowservice/v1/request_response.proto

@@ -322,6 +322,9 @@ message PollWorkflowTaskQueueRequest {
     // Worker deployment options that user has set in the worker.
     temporal.api.deployment.v1.WorkerDeploymentOptions deployment_options = 6;
 
+    // Worker-reported poller pool state. Optional.
+    temporal.api.taskqueue.v1.PollerScalingInfo poller_scaling_info = 11;
+
     // Removed in 1.55.0; was temporal.api.worker.v1.WorkerHeartbeat worker_heartbeat
     reserved 7;
     reserved "worker_heartbeat";
@@ -552,6 +555,9 @@ message PollActivityTaskQueueRequest {
     // Worker deployment options that user has set in the worker.
     temporal.api.deployment.v1.WorkerDeploymentOptions deployment_options = 6;
 
+    // Worker-reported poller pool state. Optional.
+    temporal.api.taskqueue.v1.PollerScalingInfo poller_scaling_info = 11;
+
     // Removed in 1.55.0; was temporal.api.worker.v1.WorkerHeartbeat worker_heartbeat
     reserved 7;
     reserved "worker_heartbeat";