Method Get

service/node/task.go:61–88

(c *gin.Context)

)

func (s *GetSlaveTaskService) Get(c *gin.Context) (*cluster.SlaveTaskSummary, error) {
	dep := dependency.FromContext(c)
	registry := dep.TaskRegistry()

	t, ok := registry.Get(s.ID)
	if !ok {
		return nil, serializer.NewError(serializer.CodeNotFound, "task not found", nil)
	}
	status := t.Status()
	_, clearOnComplete := c.GetQuery(routes.SlaveClearTaskRegistryQuery)
	if clearOnComplete && status == task.StatusCompleted ||
		status == task.StatusError ||
		status == task.StatusCanceled {
		registry.Delete(s.ID)
	}

	res := &cluster.SlaveTaskSummary{
		Status:       status,
		PrivateState: t.State(),
		Progress:     t.Progress(c),
	}
	err := t.Error()
	if err != nil {
		res.Error = err.Error()
	}

	return res, nil
}

func slaveTaskPropsFromContext(ctx context.Context) (*types.SlaveTaskProps, error) {
	nodeIdStr, ok := ctx.Value(cluster.SlaveNodeIDCtx{}).(string)