add ResetActivity API

temporalio · Aug 20, 2024 · 37d5afc · 37d5afc
1 parent 3d44dc8
commit 37d5afc
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 3 deletions.
diff --git a/temporal/api/workflowservice/v1/request_response.proto b/temporal/api/workflowservice/v1/request_response.proto
@@ -1702,9 +1702,24 @@ message ResumeActivityRequest {
     string activity_id = 4;
 
     bool trigger_immediately = 5;
-    bool reset_attempts = 6;
 
-    string identity = 7;
+    string identity = 6;
 }
+
 message ResumeActivityResponse {
+}
+
+message ResetActivityRequest {
+    string namespace = 1;
+    string workflow_id = 2;
+    string run_id = 3 ;
+    string activity_id = 4;
+
+    bool trigger_immediately = 5;
+    bool keep_paused = 6;
+
+    string identity = 7;
+}
+
+message ResetActivityResponse {
 }
diff --git a/temporal/api/workflowservice/v1/service.proto b/temporal/api/workflowservice/v1/service.proto
@@ -872,7 +872,7 @@ service WorkflowService {
             }
         };
     }
-    // ResumeActivity will basically unpause the activity is the activity is in the paused state.
+    // ResumeActivity will unpause the activity is the activity is in the paused state.
     rpc ResumeActivity (ResumeActivityRequest) returns (ResumeActivityResponse)
     {
         option (google.api.http) = {
@@ -884,4 +884,16 @@ service WorkflowService {
             }
         };
     }
+    // Reset will reset activity to an initial state.
+    rpc ResetActivity (ResetActivityRequest) returns (ResetActivityResponse)
+    {
+        option (google.api.http) = {
+            post: "/namespaces/{namespace}/workflows/{workflow_id}/activities/{activity_id}/reset"
+            body: "*"
+            additional_bindings {
+                post: "/api/v1/namespaces/{namespace}/workflows/{workflow_id}/activities/{activity_id}/reset"
+                body: "*"
+            }
+        };
+    }
 }