diff --git a/temporal/api/workflowservice/v1/request_response.proto b/temporal/api/workflowservice/v1/request_response.proto index 5f4cabd2..4daac87d 100644 --- 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 { } \ No newline at end of file diff --git a/temporal/api/workflowservice/v1/service.proto b/temporal/api/workflowservice/v1/service.proto index 153a6a33..62d74f08 100644 --- 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: "*" + } + }; + } }