16
}
17
18
>
func (uds *userDataStore) GetTaskQueueUserData(ctx context.Context, request *persistence.GetTaskQueueUserDataRequest) (*persistence.InternalGetTaskQueueUserDataResponse, error) {
task_user_data.go
19
>
namespaceID, err := primitives.ParseUUID(request.NamespaceID)
20
>
if err != nil {
21
return nil, serviceerror.NewInternalf("failed to parse namespace ID as UUID: %v", err)
22
}
23
>
response, err := uds.DB.GetTaskQueueUserData(ctx, &sqlplugin.GetTaskQueueUserDataRequest{
task_user_data.go
24
>
NamespaceID: namespaceID,
25
>
TaskQueueName: request.TaskQueue,
26
>
})
27
>
if err != nil {
28
if err == sql.ErrNoRows {
29
return nil, serviceerror.NewNotFoundf("task queue user data not found for %v.%v", request.NamespaceID, request.TaskQueue)