Expose eager activity reservation limit

CHANGELOG.md

@@ -32,6 +32,9 @@ to docs, or any other relevant information.
   you disable size enforcement by setting `DisablePayloadErrorLimit` to `true` on the worker.
 ### Added
 
+- Added `TemporalWorkerOptions.MaxEagerActivityReservationsPerWorkflowTask` to configure the
+  maximum number of activity slots reserved for eager execution per workflow task. Configured
+  values must be positive; use `DisableEagerActivityExecution` to disable eager execution.
 - Added the experimental `TemporalWorkerOptions.PatchActivationCallback`, allowing workers to
   decide whether a first non-replay `Workflow.Patched` call should activate a patch during rolling
   deployments.

src/Temporalio/Api/Enums/V1/Activity.cs

@@ -25,25 +25,26 @@ static ActivityReflection() {
       byte[] descriptorData = global::System.Convert.FromBase64String(
           string.Concat(
             "CiR0ZW1wb3JhbC9hcGkvZW51bXMvdjEvYWN0aXZpdHkucHJvdG8SFXRlbXBv",
-            "cmFsLmFwaS5lbnVtcy52MSq1AgoXQWN0aXZpdHlFeGVjdXRpb25TdGF0dXMS",
+            "cmFsLmFwaS5lbnVtcy52MSrbAgoXQWN0aXZpdHlFeGVjdXRpb25TdGF0dXMS",
             "KQolQUNUSVZJVFlfRVhFQ1VUSU9OX1NUQVRVU19VTlNQRUNJRklFRBAAEiUK",
             "IUFDVElWSVRZX0VYRUNVVElPTl9TVEFUVVNfUlVOTklORxABEicKI0FDVElW",
             "SVRZX0VYRUNVVElPTl9TVEFUVVNfQ09NUExFVEVEEAISJAogQUNUSVZJVFlf",
             "RVhFQ1VUSU9OX1NUQVRVU19GQUlMRUQQAxImCiJBQ1RJVklUWV9FWEVDVVRJ",
             "T05fU1RBVFVTX0NBTkNFTEVEEAQSKAokQUNUSVZJVFlfRVhFQ1VUSU9OX1NU",
             "QVRVU19URVJNSU5BVEVEEAUSJwojQUNUSVZJVFlfRVhFQ1VUSU9OX1NUQVRV",
-            "U19USU1FRF9PVVQQBirYAQoVQWN0aXZpdHlJZFJldXNlUG9saWN5EigKJEFD",
-            "VElWSVRZX0lEX1JFVVNFX1BPTElDWV9VTlNQRUNJRklFRBAAEiwKKEFDVElW",
-            "SVRZX0lEX1JFVVNFX1BPTElDWV9BTExPV19EVVBMSUNBVEUQARI4CjRBQ1RJ",
-            "VklUWV9JRF9SRVVTRV9QT0xJQ1lfQUxMT1dfRFVQTElDQVRFX0ZBSUxFRF9P",
-            "TkxZEAISLQopQUNUSVZJVFlfSURfUkVVU0VfUE9MSUNZX1JFSkVDVF9EVVBM",
-            "SUNBVEUQAyqbAQoYQWN0aXZpdHlJZENvbmZsaWN0UG9saWN5EisKJ0FDVElW",
-            "SVRZX0lEX0NPTkZMSUNUX1BPTElDWV9VTlNQRUNJRklFRBAAEiQKIEFDVElW",
-            "SVRZX0lEX0NPTkZMSUNUX1BPTElDWV9GQUlMEAESLAooQUNUSVZJVFlfSURf",
-            "Q09ORkxJQ1RfUE9MSUNZX1VTRV9FWElTVElORxACQoUBChhpby50ZW1wb3Jh",
-            "bC5hcGkuZW51bXMudjFCDUFjdGl2aXR5UHJvdG9QAVohZ28udGVtcG9yYWwu",
-            "aW8vYXBpL2VudW1zL3YxO2VudW1zqgIXVGVtcG9yYWxpby5BcGkuRW51bXMu",
-            "VjHqAhpUZW1wb3JhbGlvOjpBcGk6OkVudW1zOjpWMWIGcHJvdG8z"));
+            "U19USU1FRF9PVVQQBhIkCiBBQ1RJVklUWV9FWEVDVVRJT05fU1RBVFVTX1BB",
+            "VVNFRBAHKtgBChVBY3Rpdml0eUlkUmV1c2VQb2xpY3kSKAokQUNUSVZJVFlf",
+            "SURfUkVVU0VfUE9MSUNZX1VOU1BFQ0lGSUVEEAASLAooQUNUSVZJVFlfSURf",
+            "UkVVU0VfUE9MSUNZX0FMTE9XX0RVUExJQ0FURRABEjgKNEFDVElWSVRZX0lE",
+            "X1JFVVNFX1BPTElDWV9BTExPV19EVVBMSUNBVEVfRkFJTEVEX09OTFkQAhIt",
+            "CilBQ1RJVklUWV9JRF9SRVVTRV9QT0xJQ1lfUkVKRUNUX0RVUExJQ0FURRAD",
+            "KpsBChhBY3Rpdml0eUlkQ29uZmxpY3RQb2xpY3kSKwonQUNUSVZJVFlfSURf",
+            "Q09ORkxJQ1RfUE9MSUNZX1VOU1BFQ0lGSUVEEAASJAogQUNUSVZJVFlfSURf",
+            "Q09ORkxJQ1RfUE9MSUNZX0ZBSUwQARIsCihBQ1RJVklUWV9JRF9DT05GTElD",
+            "VF9QT0xJQ1lfVVNFX0VYSVNUSU5HEAJChQEKGGlvLnRlbXBvcmFsLmFwaS5l",
+            "bnVtcy52MUINQWN0aXZpdHlQcm90b1ABWiFnby50ZW1wb3JhbC5pby9hcGkv",
+            "ZW51bXMvdjE7ZW51bXOqAhdUZW1wb3JhbGlvLkFwaS5FbnVtcy5WMeoCGlRl",
+            "bXBvcmFsaW86OkFwaTo6RW51bXM6OlYxYgZwcm90bzM="));
       descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
           new pbr::FileDescriptor[] { },
           new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Temporalio.Api.Enums.V1.ActivityExecutionStatus), typeof(global::Temporalio.Api.Enums.V1.ActivityIdReusePolicy), typeof(global::Temporalio.Api.Enums.V1.ActivityIdConflictPolicy), }, null, null));
@@ -54,8 +55,8 @@ static ActivityReflection() {
   #region Enums
   /// <summary>
   /// Status of a standalone activity.
-  /// The status is updated once, when the activity is originally scheduled, and again when the activity reaches a terminal
-  /// status.
+  /// The status is updated when the activity is originally scheduled, paused, unpaused, and when the
+  /// activity reaches a terminal state.
   /// (-- api-linter: core::0216::synonyms=disabled
   ///     aip.dev/not-precedent: Named consistently with WorkflowExecutionStatus. --)
   /// </summary>
@@ -101,6 +102,11 @@ public enum ActivityExecutionStatus {
     ///   SCHEDULE_TO_CLOSE would be exceeded, or cancellation has been requested).
     /// </summary>
     [pbr::OriginalName("ACTIVITY_EXECUTION_STATUS_TIMED_OUT")] TimedOut = 6,
+    /// <summary>
+    /// The activity is paused. Paused state is only reachable after calling
+    /// PauseActivityExecution on a standalone activity.
+    /// </summary>
+    [pbr::OriginalName("ACTIVITY_EXECUTION_STATUS_PAUSED")] Paused = 7,
   }
 
   /// <summary>

src/Temporalio/Api/Enums/V1/BatchOperation.cs

@@ -25,23 +25,33 @@ static BatchOperationReflection() {
       byte[] descriptorData = global::System.Convert.FromBase64String(
           string.Concat(
             "Cit0ZW1wb3JhbC9hcGkvZW51bXMvdjEvYmF0Y2hfb3BlcmF0aW9uLnByb3Rv",
-            "EhV0ZW1wb3JhbC5hcGkuZW51bXMudjEqmgMKEkJhdGNoT3BlcmF0aW9uVHlw",
-            "ZRIkCiBCQVRDSF9PUEVSQVRJT05fVFlQRV9VTlNQRUNJRklFRBAAEiIKHkJB",
-            "VENIX09QRVJBVElPTl9UWVBFX1RFUk1JTkFURRABEh8KG0JBVENIX09QRVJB",
-            "VElPTl9UWVBFX0NBTkNFTBACEh8KG0JBVENIX09QRVJBVElPTl9UWVBFX1NJ",
-            "R05BTBADEh8KG0JBVENIX09QRVJBVElPTl9UWVBFX0RFTEVURRAEEh4KGkJB",
-            "VENIX09QRVJBVElPTl9UWVBFX1JFU0VUEAUSMQotQkFUQ0hfT1BFUkFUSU9O",
-            "X1RZUEVfVVBEQVRFX0VYRUNVVElPTl9PUFRJT05TEAYSKQolQkFUQ0hfT1BF",
-            "UkFUSU9OX1RZUEVfVU5QQVVTRV9BQ1RJVklUWRAHEjAKLEJBVENIX09QRVJB",
-            "VElPTl9UWVBFX1VQREFURV9BQ1RJVklUWV9PUFRJT05TEAgSJwojQkFUQ0hf",
-            "T1BFUkFUSU9OX1RZUEVfUkVTRVRfQUNUSVZJVFkQCSqmAQoTQmF0Y2hPcGVy",
-            "YXRpb25TdGF0ZRIlCiFCQVRDSF9PUEVSQVRJT05fU1RBVEVfVU5TUEVDSUZJ",
-            "RUQQABIhCh1CQVRDSF9PUEVSQVRJT05fU1RBVEVfUlVOTklORxABEiMKH0JB",
-            "VENIX09QRVJBVElPTl9TVEFURV9DT01QTEVURUQQAhIgChxCQVRDSF9PUEVS",
-            "QVRJT05fU1RBVEVfRkFJTEVEEANCiwEKGGlvLnRlbXBvcmFsLmFwaS5lbnVt",
-            "cy52MUITQmF0Y2hPcGVyYXRpb25Qcm90b1ABWiFnby50ZW1wb3JhbC5pby9h",
-            "cGkvZW51bXMvdjE7ZW51bXOqAhdUZW1wb3JhbGlvLkFwaS5FbnVtcy5WMeoC",
-            "GlRlbXBvcmFsaW86OkFwaTo6RW51bXM6OlYxYgZwcm90bzM="));
+            "EhV0ZW1wb3JhbC5hcGkuZW51bXMudjEqwwYKEkJhdGNoT3BlcmF0aW9uVHlw",
+            "ZRIkCiBCQVRDSF9PUEVSQVRJT05fVFlQRV9VTlNQRUNJRklFRBAAEiYKHkJB",
+            "VENIX09QRVJBVElPTl9UWVBFX1RFUk1JTkFURRABGgIIARIrCidCQVRDSF9P",
+            "UEVSQVRJT05fVFlQRV9URVJNSU5BVEVfV09SS0ZMT1cQDRIjChtCQVRDSF9P",
+            "UEVSQVRJT05fVFlQRV9DQU5DRUwQAhoCCAESKAokQkFUQ0hfT1BFUkFUSU9O",
+            "X1RZUEVfQ0FOQ0VMX1dPUktGTE9XEA4SIwobQkFUQ0hfT1BFUkFUSU9OX1RZ",
+            "UEVfU0lHTkFMEAMaAggBEigKJEJBVENIX09QRVJBVElPTl9UWVBFX1NJR05B",
+            "TF9XT1JLRkxPVxAPEiMKG0JBVENIX09QRVJBVElPTl9UWVBFX0RFTEVURRAE",
+            "GgIIARIoCiRCQVRDSF9PUEVSQVRJT05fVFlQRV9ERUxFVEVfV09SS0ZMT1cQ",
+            "EBIiChpCQVRDSF9PUEVSQVRJT05fVFlQRV9SRVNFVBAFGgIIARInCiNCQVRD",
+            "SF9PUEVSQVRJT05fVFlQRV9SRVNFVF9XT1JLRkxPVxAREjUKLUJBVENIX09Q",
+            "RVJBVElPTl9UWVBFX1VQREFURV9FWEVDVVRJT05fT1BUSU9OUxAGGgIIARI6",
+            "CjZCQVRDSF9PUEVSQVRJT05fVFlQRV9VUERBVEVfV09SS0ZMT1dfRVhFQ1VU",
+            "SU9OX09QVElPTlMQEhIpCiVCQVRDSF9PUEVSQVRJT05fVFlQRV9VTlBBVVNF",
+            "X0FDVElWSVRZEAcSMAosQkFUQ0hfT1BFUkFUSU9OX1RZUEVfVVBEQVRFX0FD",
+            "VElWSVRZX09QVElPTlMQCBInCiNCQVRDSF9PUEVSQVRJT05fVFlQRV9SRVNF",
+            "VF9BQ1RJVklUWRAJEisKJ0JBVENIX09QRVJBVElPTl9UWVBFX1RFUk1JTkFU",
+            "RV9BQ1RJVklUWRAKEigKJEJBVENIX09QRVJBVElPTl9UWVBFX0NBTkNFTF9B",
+            "Q1RJVklUWRALEigKJEJBVENIX09QRVJBVElPTl9UWVBFX0RFTEVURV9BQ1RJ",
+            "VklUWRAMKqYBChNCYXRjaE9wZXJhdGlvblN0YXRlEiUKIUJBVENIX09QRVJB",
+            "VElPTl9TVEFURV9VTlNQRUNJRklFRBAAEiEKHUJBVENIX09QRVJBVElPTl9T",
+            "VEFURV9SVU5OSU5HEAESIwofQkFUQ0hfT1BFUkFUSU9OX1NUQVRFX0NPTVBM",
+            "RVRFRBACEiAKHEJBVENIX09QRVJBVElPTl9TVEFURV9GQUlMRUQQA0KLAQoY",
+            "aW8udGVtcG9yYWwuYXBpLmVudW1zLnYxQhNCYXRjaE9wZXJhdGlvblByb3Rv",
+            "UAFaIWdvLnRlbXBvcmFsLmlvL2FwaS9lbnVtcy92MTtlbnVtc6oCF1RlbXBv",
+            "cmFsaW8uQXBpLkVudW1zLlYx6gIaVGVtcG9yYWxpbzo6QXBpOjpFbnVtczo6",
+            "VjFiBnByb3RvMw=="));
       descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
           new pbr::FileDescriptor[] { },
           new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Temporalio.Api.Enums.V1.BatchOperationType), typeof(global::Temporalio.Api.Enums.V1.BatchOperationState), }, null, null));
@@ -52,15 +62,48 @@ static BatchOperationReflection() {
   #region Enums
   public enum BatchOperationType {
     [pbr::OriginalName("BATCH_OPERATION_TYPE_UNSPECIFIED")] Unspecified = 0,
+    /// <summary>
+    /// DEPRECATED: Use BATCH_OPERATION_TYPE_TERMINATE_WORKFLOW instead.
+    /// </summary>
+    [global::System.ObsoleteAttribute]
     [pbr::OriginalName("BATCH_OPERATION_TYPE_TERMINATE")] Terminate = 1,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_TERMINATE_WORKFLOW")] TerminateWorkflow = 13,
+    /// <summary>
+    /// DEPRECATED: Use BATCH_OPERATION_TYPE_CANCEL_WORKFLOW instead.
+    /// </summary>
+    [global::System.ObsoleteAttribute]
     [pbr::OriginalName("BATCH_OPERATION_TYPE_CANCEL")] Cancel = 2,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_CANCEL_WORKFLOW")] CancelWorkflow = 14,
+    /// <summary>
+    /// DEPRECATED: Use BATCH_OPERATION_TYPE_SIGNAL_WORKFLOW instead.
+    /// </summary>
+    [global::System.ObsoleteAttribute]
     [pbr::OriginalName("BATCH_OPERATION_TYPE_SIGNAL")] Signal = 3,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_SIGNAL_WORKFLOW")] SignalWorkflow = 15,
+    /// <summary>
+    /// DEPRECATED: Use BATCH_OPERATION_TYPE_DELETE_WORKFLOW instead.
+    /// </summary>
+    [global::System.ObsoleteAttribute]
     [pbr::OriginalName("BATCH_OPERATION_TYPE_DELETE")] Delete = 4,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_DELETE_WORKFLOW")] DeleteWorkflow = 16,
+    /// <summary>
+    /// DEPRECATED: Use BATCH_OPERATION_TYPE_RESET_WORKFLOW instead.
+    /// </summary>
+    [global::System.ObsoleteAttribute]
     [pbr::OriginalName("BATCH_OPERATION_TYPE_RESET")] Reset = 5,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_RESET_WORKFLOW")] ResetWorkflow = 17,
+    /// <summary>
+    /// DEPRECATED: Use BATCH_OPERATION_TYPE_UPDATE_WORKFLOW_EXECUTION_OPTIONS instead.
+    /// </summary>
+    [global::System.ObsoleteAttribute]
     [pbr::OriginalName("BATCH_OPERATION_TYPE_UPDATE_EXECUTION_OPTIONS")] UpdateExecutionOptions = 6,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_UPDATE_WORKFLOW_EXECUTION_OPTIONS")] UpdateWorkflowExecutionOptions = 18,
     [pbr::OriginalName("BATCH_OPERATION_TYPE_UNPAUSE_ACTIVITY")] UnpauseActivity = 7,
     [pbr::OriginalName("BATCH_OPERATION_TYPE_UPDATE_ACTIVITY_OPTIONS")] UpdateActivityOptions = 8,
     [pbr::OriginalName("BATCH_OPERATION_TYPE_RESET_ACTIVITY")] ResetActivity = 9,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_TERMINATE_ACTIVITY")] TerminateActivity = 10,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_CANCEL_ACTIVITY")] CancelActivity = 11,
+    [pbr::OriginalName("BATCH_OPERATION_TYPE_DELETE_ACTIVITY")] DeleteActivity = 12,
   }
 
   public enum BatchOperationState {

src/Temporalio/Api/Enums/V1/Common.cs

@@ -63,14 +63,16 @@ static CommonReflection() {
             "EiUKIUFQUExJQ0FUSU9OX0VSUk9SX0NBVEVHT1JZX0JFTklHThABKoUBCgxX",
             "b3JrZXJTdGF0dXMSHQoZV09SS0VSX1NUQVRVU19VTlNQRUNJRklFRBAAEhkK",
             "FVdPUktFUl9TVEFUVVNfUlVOTklORxABEh8KG1dPUktFUl9TVEFUVVNfU0hV",
-            "VFRJTkdfRE9XThACEhoKFldPUktFUl9TVEFUVVNfU0hVVERPV04QA0KDAQoY",
-            "aW8udGVtcG9yYWwuYXBpLmVudW1zLnYxQgtDb21tb25Qcm90b1ABWiFnby50",
-            "ZW1wb3JhbC5pby9hcGkvZW51bXMvdjE7ZW51bXOqAhdUZW1wb3JhbGlvLkFw",
-            "aS5FbnVtcy5WMeoCGlRlbXBvcmFsaW86OkFwaTo6RW51bXM6OlYxYgZwcm90",
-            "bzM="));
+            "VFRJTkdfRE9XThACEhoKFldPUktFUl9TVEFUVVNfU0hVVERPV04QAyppCg1F",
+            "eGVjdXRpb25UeXBlEh4KGkVYRUNVVElPTl9UWVBFX1VOU1BFQ0lGSUVEEAAS",
+            "GwoXRVhFQ1VUSU9OX1RZUEVfV09SS0ZMT1cQARIbChdFWEVDVVRJT05fVFlQ",
+            "RV9BQ1RJVklUWRACQoMBChhpby50ZW1wb3JhbC5hcGkuZW51bXMudjFCC0Nv",
+            "bW1vblByb3RvUAFaIWdvLnRlbXBvcmFsLmlvL2FwaS9lbnVtcy92MTtlbnVt",
+            "c6oCF1RlbXBvcmFsaW8uQXBpLkVudW1zLlYx6gIaVGVtcG9yYWxpbzo6QXBp",
+            "OjpFbnVtczo6VjFiBnByb3RvMw=="));
       descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
           new pbr::FileDescriptor[] { },
-          new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Temporalio.Api.Enums.V1.EncodingType), typeof(global::Temporalio.Api.Enums.V1.IndexedValueType), typeof(global::Temporalio.Api.Enums.V1.Severity), typeof(global::Temporalio.Api.Enums.V1.CallbackState), typeof(global::Temporalio.Api.Enums.V1.PendingNexusOperationState), typeof(global::Temporalio.Api.Enums.V1.NexusOperationCancellationState), typeof(global::Temporalio.Api.Enums.V1.WorkflowRuleActionScope), typeof(global::Temporalio.Api.Enums.V1.ApplicationErrorCategory), typeof(global::Temporalio.Api.Enums.V1.WorkerStatus), }, null, null));
+          new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Temporalio.Api.Enums.V1.EncodingType), typeof(global::Temporalio.Api.Enums.V1.IndexedValueType), typeof(global::Temporalio.Api.Enums.V1.Severity), typeof(global::Temporalio.Api.Enums.V1.CallbackState), typeof(global::Temporalio.Api.Enums.V1.PendingNexusOperationState), typeof(global::Temporalio.Api.Enums.V1.NexusOperationCancellationState), typeof(global::Temporalio.Api.Enums.V1.WorkflowRuleActionScope), typeof(global::Temporalio.Api.Enums.V1.ApplicationErrorCategory), typeof(global::Temporalio.Api.Enums.V1.WorkerStatus), typeof(global::Temporalio.Api.Enums.V1.ExecutionType), }, null, null));
     }
     #endregion
 
@@ -228,6 +230,18 @@ public enum WorkerStatus {
     [pbr::OriginalName("WORKER_STATUS_SHUTDOWN")] Shutdown = 3,
   }
 
+  public enum ExecutionType {
+    [pbr::OriginalName("EXECUTION_TYPE_UNSPECIFIED")] Unspecified = 0,
+    /// <summary>
+    /// A workflow execution archetype. 
+    /// </summary>
+    [pbr::OriginalName("EXECUTION_TYPE_WORKFLOW")] Workflow = 1,
+    /// <summary>
+    /// An activity execution archetype. This is reserved for standalone activities.
+    /// </summary>
+    [pbr::OriginalName("EXECUTION_TYPE_ACTIVITY")] Activity = 2,
+  }
+
   #endregion
 
 }