207
ctx context.Context,
208
request *GetTasksRequest,
210
>
if request.InclusiveMinTaskID >= request.ExclusiveMaxTaskID {
211
return &GetTasksResponse{}, nil
212
}
213
214
>
internalResp, err := m.taskStore.GetTasks(ctx, request)
task_manager.go
215
>
if err != nil {
216
return nil, err
217
}
218
>
tasks := make([]*persistencespb.AllocatedTaskInfo, len(internalResp.Tasks))
task_manager.go
219
>
for i, taskBlob := range internalResp.Tasks {
220
task, err := m.serializer.TaskInfoFromBlob(taskBlob)
221
if err != nil {