code: func FinishExecutionFn(c context.Context, eid *dm.Execution_ID, rslt *dm.Result) ([]tumble.Mutation, error) {
  	if rslt.Data != nil {
  		if normErr := rslt.Data.Normalize(); normErr != nil {
  			logging.WithError(normErr).Errorf(c, "Could not normalize distributor Result!")
  			rslt = &dm.Result{
  				AbnormalFinish: &dm.AbnormalFinish{
  					Status: dm.AbnormalFinish_RESULT_MALFORMED,
  					Reason: fmt.Sprintf("distributor result malformed: %q in %q", normErr, rslt.Data.Object),
  				},
  			}
  		}
  	}
  
  	return []tumble.Mutation{&FinishExecution{EID: eid, Result: rslt}}, nil
  }
docs: // FinishExecutionFn is the implementation of distributor.FinishExecutionFn.
  // It's defined here to avoid a circular dependency.