mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-30 14:56:19 +00:00
## What changed? - Added UnpauseWorkflowExecution() APIs and wired it up in frontend & history - Added/modified functional tests ## Why? This API allows us to implement the unpause operation command. ## How did you test it? - [x] built - [ ] run locally and tested manually - [x] covered by existing tests - [ ] added new unit test(s) - [x] added new functional test(s) --- > [!NOTE] > Introduces UnpauseWorkflowExecution across proto, gRPC, clients, frontend, and history with logging/metrics and functional tests. > > - **API/Protobuf**: > - Add `UnpauseWorkflowExecutionRequest/Response` to `request_response.proto` and generated files; include routing and helpers in `request_response.go-helpers.pb.go`. > - Extend `service.proto` with `UnpauseWorkflowExecution` RPC; regenerate `service.pb.go`/`service_grpc.pb.go`. > - **gRPC & Mocks**: > - Add client/server methods, handlers, and method constants for `UnpauseWorkflowExecution`. > - Update mocks in `api/historyservicemock/v1/service_grpc.pb.mock.go`. > - **Clients**: > - Implement `UnpauseWorkflowExecution` in `client/history/client_gen.go`, `metric_client_gen.go`, and `retryable_client_gen.go` (shard routing, metrics, retries). > - **History Service**: > - Implement unpause logic in `service/history/api/unpauseworkflow/api.go` (validate, ensure paused, add unpaused event, create workflow task). > - Wire through engine (`history_engine.go`), handler (`handler.go`), and interfaces (`interfaces/engine.go` + mocks). > - Add log tags in `common/rpc/interceptor/logtags/history_service_server_gen.go` and telemetry in `common/rpc/interceptor/telemetry.go`. > - **Frontend**: > - Add `WorkflowHandler.UnpauseWorkflowExecution` to validate inputs and call history. > - **Tests**: > - Update functional tests to cover pause→unpause flow and request validation in `tests/pause_workflow_execution_test.go`. > > <sup>Written by [Cursor Bugbot]() for commit 79909baa02fb5c394536a6c47b048fd21caf9047. This will update automatically on new commits. Configure [here]().</sup>