183
}
184
185
>
if _, err := m.DB.RangeDeleteFromHistoryImmediateTasks(ctx, sqlplugin.HistoryImmediateTasksRangeFilter{
execution_tasks.go
186
>
ShardID: request.ShardID,
187
>
CategoryID: int32(categoryID),
188
>
InclusiveMinTaskID: request.InclusiveMinTaskKey.TaskID,
189
>
ExclusiveMaxTaskID: request.ExclusiveMaxTaskKey.TaskID,
190
>
}); err != nil {
191
return serviceerror.NewUnavailablef(
192
"RangeCompleteTransferTask operation failed. CategoryID: %v. Error: %v", categoryID, err,
193
)
194
}
196
}
197