Download Stats

Author: simvlad

temporal/api/common/v1/message.proto

@@ -347,3 +347,19 @@ message WorkerSelector {
     }
 }
 
+// Stats about external payloads downloaded by SDK during workflow task processing.
+message ExternalPayloadDownloadStats {
+  // Number of external payloads downloaded.
+  int64 payload_count = 1;
+
+  // Total size in bytes of downloaded payloads.
+  int64 total_size_bytes = 2;
+
+  // Wall time spent downloading (milliseconds).
+  int64 download_duration_ms = 3;
+
+  // True if any portion of this workflow task processed history in replay mode
+  // (i.e., SDK had to rebuild state) and downloaded payloads during that period.
+  bool replay_involved = 4;
+}
+

temporal/api/history/v1/message.proto

@@ -330,6 +330,8 @@ message WorkflowTaskCompletedEventAttributes {
     // is set. This value updates workflow execution's `versioning_info.deployment_version`.
     // Experimental. Worker Deployments are experimental and might significantly change in the future.
     temporal.api.deployment.v1.WorkerDeploymentVersion deployment_version = 11;
+    // Stats about external payloads downloaded by SDK.
+    temporal.api.common.v1.ExternalPayloadDownloadStats external_payload_stats = 12;
 }
 
 message WorkflowTaskTimedOutEventAttributes {
@@ -366,6 +368,8 @@ message WorkflowTaskFailedEventAttributes {
     // populated to preserve compatibility).
     // Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
     temporal.api.common.v1.WorkerVersionStamp worker_version = 10 [deprecated = true];
+    // Stats about external payloads downloaded by SDK.
+    temporal.api.common.v1.ExternalPayloadDownloadStats external_payload_stats = 11;
 }
 
 message ActivityTaskScheduledEventAttributes {

temporal/api/workflowservice/v1/request_response.proto

@@ -372,6 +372,8 @@ message RespondWorkflowTaskCompletedRequest {
     temporal.api.enums.v1.VersioningBehavior versioning_behavior = 16;
     // Worker deployment options that user has set in the worker.
     temporal.api.deployment.v1.WorkerDeploymentOptions deployment_options = 17;
+    // Stats about external payloads downloaded by SDK.
+    temporal.api.common.v1.ExternalPayloadDownloadStats external_payload_stats = 18;
 
     // SDK capability details.
     message Capabilities {
@@ -423,6 +425,8 @@ message RespondWorkflowTaskFailedRequest {
     temporal.api.deployment.v1.Deployment deployment = 9 [deprecated = true];
     // Worker deployment options that user has set in the worker.
     temporal.api.deployment.v1.WorkerDeploymentOptions deployment_options = 10;
+    // Stats about external payloads downloaded by SDK.
+    temporal.api.common.v1.ExternalPayloadDownloadStats external_payload_stats = 11;
 }
 
 message RespondWorkflowTaskFailedResponse {