(ctx context.Context)
| 786 | } |
| 787 | |
| 788 | func (s *shimTask) Wait(ctx context.Context) (*runtime.Exit, error) { |
| 789 | taskPid, err := s.PID(ctx) |
| 790 | if err != nil { |
| 791 | return nil, err |
| 792 | } |
| 793 | response, err := s.task.Wait(ctx, &task.WaitRequest{ |
| 794 | ID: s.ID(), |
| 795 | }) |
| 796 | if err != nil { |
| 797 | return nil, errgrpc.ToNative(err) |
| 798 | } |
| 799 | return &runtime.Exit{ |
| 800 | Pid: taskPid, |
| 801 | Timestamp: protobuf.FromTimestamp(response.ExitedAt), |
| 802 | Status: response.ExitStatus, |
| 803 | }, nil |
| 804 | } |
| 805 | |
| 806 | func (s *shimTask) Checkpoint(ctx context.Context, path string, options *ptypes.Any) error { |
| 807 | request := &task.CheckpointTaskRequest{ |
nothing calls this directly
no test coverage detected