Initial distributor implementation

appengine/cmd/dm/deps/finish_attempt.go

Index: appengine/cmd/dm/deps/finish_attempt.go
diff --git a/appengine/cmd/dm/deps/finish_attempt.go b/appengine/cmd/dm/deps/finish_attempt.go
index 70bddb786701bfec44f949faa5324d3a1ed71113..6a71fa2bf9dfb699a7d61dc5dac0c7f21b75c41b 100644
--- a/appengine/cmd/dm/deps/finish_attempt.go
+++ b/appengine/cmd/dm/deps/finish_attempt.go
@@ -20,6 +20,7 @@ import (
 const resultMaxLength = 256 * 1024
 
 func (d *deps) FinishAttempt(c context.Context, req *dm.FinishAttemptReq) (_ *google_pb.Empty, err error) {
+	logging.Fields{"execution": req.Auth.Id}.Infof(c, "finishing")
 	if len(req.JsonResult) > resultMaxLength {
 		return nil, fmt.Errorf("result payload is too large: %d > %d",
 			len(req.JsonResult), resultMaxLength)
@@ -27,11 +28,11 @@ func (d *deps) FinishAttempt(c context.Context, req *dm.FinishAttemptReq) (_ *go
 
 	req.JsonResult, err = template.NormalizeJSON(req.JsonResult, true)
 	if err != nil {
-		logging.WithError(err).Infof(c, "failed to normalized json")
-		return nil, grpcutil.Errf(codes.InvalidArgument, "resuld json had normalization error: %s", err.Error())
+		logging.WithError(err).Infof(c, "failed to normalize json")
+		return nil, grpcutil.Errf(codes.InvalidArgument, "result json had normalization error: %s", err.Error())
 	}
 
-	return nil, tumbleNow(c, &mutate.FinishAttempt{
+	return &google_pb.Empty{}, tumbleNow(c, &mutate.FinishAttempt{
 		Auth:             req.Auth,
 		Result:           req.JsonResult,
 		ResultExpiration: req.Expiration.Time(),