(ctx context.Context)
| 707 | } |
| 708 | |
| 709 | func (t *task) Metrics(ctx context.Context) (*types.Metric, error) { |
| 710 | response, err := t.client.TaskService().Metrics(ctx, &tasks.MetricsRequest{ |
| 711 | Filters: []string{ |
| 712 | "id==" + t.id, |
| 713 | }, |
| 714 | }) |
| 715 | if err != nil { |
| 716 | return nil, errgrpc.ToNative(err) |
| 717 | } |
| 718 | |
| 719 | if response.Metrics == nil { |
| 720 | _, err := t.Status(ctx) |
| 721 | if err != nil && errdefs.IsNotFound(err) { |
| 722 | return nil, err |
| 723 | } |
| 724 | return nil, errors.New("no metrics received") |
| 725 | } |
| 726 | |
| 727 | return response.Metrics[0], nil |
| 728 | } |
| 729 | |
| 730 | func (t *task) checkpointTask(ctx context.Context, index *v1.Index, request *tasks.CheckpointTaskRequest) error { |
| 731 | response, err := t.client.TaskService().Checkpoint(ctx, request) |
nothing calls this directly
no test coverage detected