code: func (s *session) sendTaskStatus(ctx context.Context, taskID string, taskStatus *api.TaskStatus) error {
  	client := api.NewDispatcherClient(s.conn.ClientConn)
  	if _, err := client.UpdateTaskStatus(ctx, &api.UpdateTaskStatusRequest{
  		SessionID: s.sessionID,
  		Updates: []*api.UpdateTaskStatusRequest_TaskStatusUpdate{
  			{
  				TaskID: taskID,
  				Status: taskStatus,
  			},
  		},
  	}); err != nil {
  		// TODO(stevvooe): Dispatcher should not return this error. Status
  		// reports for unknown tasks should be ignored.
  		st, _ := status.FromError(err)
  		if st.Code() == codes.NotFound {
  			return errTaskUnknown
  		}
  
  		return err
  	}
  
  	return nil
  }
docs: // sendTaskStatus uses the current session to send the status of a single task.