resp := &p.InternalGetHistoryTasksResponse{Tasks: make([]p.InternalHistoryTask, 0, len(rows))}
for _, row := range rows {
Key: tasks.NewKey(row.VisibilityTimestamp, row.TaskID),
Blob: p.NewDataBlob(row.Data, row.DataEncoding),
})
}
if len(resp.Tasks) == request.BatchSize {