Get task detail from queue usecase

[sandl99]

Hi masters,

var getValueFromHashCmd = redis.NewScript(`
return redis.call("HGET", KEYS[1], "msg")
`)

func GetTaskPayloadFromTaskQueue(ctx context.Context, redisClient redis.UniversalClient, queue, taskId string) ([]byte, error) {
	keys := []string{base.TaskKey(queue, taskId)}
	res, err := getValueFromHashCmd.Run(ctx, redisClient, keys).Result()
	if err != nil {
		return nil, err
	}

	encoded, err := cast.ToStringE(res)
	if err != nil {
		return nil, err
	}
	msg, err := base.DecodeMessage([]byte(encoded))
	if err != nil {
		return nil, err
	}

	return msg.Payload, nil
}

I have an usecase like this. I would like to extract payload from a task which is already on the queue (no matter pending queue, active queue...) .
In above code, I couldn't compile code because of the restriction of compiler which don't allow import internal packages. So Is any idea for this usecase without forking your repository and customizing it ?

[sandl99]

I see asynq.Inspector could support me in this case