TaskStatus retrieves metadata for a given task ID.
(ctx context.Context, req *pb.TaskStatusRequest, )
| 67 | |
| 68 | // TaskStatus retrieves metadata for a given task ID. |
| 69 | func (*grpcWorker) TaskStatus(ctx context.Context, req *pb.TaskStatusRequest, |
| 70 | ) (*pb.TaskStatusResponse, error) { |
| 71 | taskId := req.GetTaskId() |
| 72 | meta, err := Tasks.get(taskId) |
| 73 | if err != nil { |
| 74 | return nil, err |
| 75 | } |
| 76 | |
| 77 | resp := &pb.TaskStatusResponse{TaskMeta: meta.uint64()} |
| 78 | return resp, nil |
| 79 | } |
| 80 | |
| 81 | var ( |
| 82 | // Tasks is a global persistent task queue. |