Files
tasks/service/history/api/deletedlqtasks/api.go
zeekay 5a601d081b rebrand: go.temporal.io/server -> github.com/hanzoai/tasks
Full module path rebrand from Temporal to Hanzo Tasks:
- go.mod module: github.com/hanzoai/tasks
- All internal Go imports updated (1906 files)
- cmd/server renamed to cmd/tasksd
- Binary name: tasksd (was temporal-server)
- Docker images: hanzoai/tasks (was temporalio/server)
- README rewritten with Hanzo Tasks branding
- LLM.md created with integration notes
- Makefile, goreleaser, CI workflows updated
- go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos)

Fork of Temporal.io (MIT license).
2026-03-19 10:36:40 -07:00

45 lines
1.3 KiB
Go

package deletedlqtasks
import (
"context"
"go.temporal.io/api/serviceerror"
"github.com/hanzoai/tasks/api/historyservice/v1"
"github.com/hanzoai/tasks/common/persistence"
"github.com/hanzoai/tasks/service/history/api"
"github.com/hanzoai/tasks/service/history/tasks"
)
func Invoke(
ctx context.Context,
historyTaskQueueManager persistence.HistoryTaskQueueManager,
req *historyservice.DeleteDLQTasksRequest,
registry tasks.TaskCategoryRegistry,
) (*historyservice.DeleteDLQTasksResponse, error) {
category, err := api.GetTaskCategory(int(req.DlqKey.TaskCategory), registry)
if err != nil {
return nil, err
}
if req.InclusiveMaxTaskMetadata == nil {
return nil, serviceerror.NewInvalidArgument("must supply inclusive_max_task_metadata")
}
resp, err := historyTaskQueueManager.DeleteTasks(ctx, &persistence.DeleteTasksRequest{
QueueKey: persistence.QueueKey{
QueueType: persistence.QueueTypeHistoryDLQ,
Category: category,
SourceCluster: req.DlqKey.SourceCluster,
TargetCluster: req.DlqKey.TargetCluster,
},
InclusiveMaxMessageMetadata: persistence.MessageMetadata{
ID: req.InclusiveMaxTaskMetadata.MessageId,
},
})
if err != nil {
return nil, err
}
return &historyservice.DeleteDLQTasksResponse{MessagesDeleted: resp.MessagesDeleted}, nil
}