code: func (e *edge) finishIncoming(req pipe.Sender) {
  	err := e.err
  	if req.Request().Canceled && err == nil {
  		err = context.Canceled
  	}
  	if debugScheduler {
  		logrus.Debugf("finishIncoming %s %v %#v desired=%s", e.edge.Vertex.Name(), err, e.edgeState, req.Request().Payload.(*edgeRequest).desiredState)
  	}
  	req.Finalize(&e.edgeState, err)
  }
docs: // finishIncoming finalizes the incoming pipe request