Initial distributor implementation

appengine/cmd/dm/mutate/add_finished_deps.go

Index: appengine/cmd/dm/mutate/add_finished_deps.go
diff --git a/appengine/cmd/dm/mutate/add_finished_deps.go b/appengine/cmd/dm/mutate/add_finished_deps.go
index de6ae35d5f2e579b493d5784f6282b66ca30d2a1..4a6fe25568471f190be10c6f80f0314055061c4a 100644
--- a/appengine/cmd/dm/mutate/add_finished_deps.go
+++ b/appengine/cmd/dm/mutate/add_finished_deps.go
@@ -28,7 +28,7 @@ type AddFinishedDeps struct {
 
 // Root implements tumble.Mutation
 func (f *AddFinishedDeps) Root(c context.Context) *datastore.Key {
-	return datastore.Get(c).KeyForObj(&model.Attempt{ID: *f.Auth.Id.AttemptID()})
+	return model.AttemptKeyFromID(c, f.Auth.Id.AttemptID())
 }
 
 // RollForward implements tumble.Mutation
@@ -49,7 +49,7 @@ func (f *AddFinishedDeps) RollForward(c context.Context) (muts []tumble.Mutation
 		muts = append(muts, &AddBackDep{Dep: d.Edge()})
 	}
 	for _, q := range f.MergeQuests {
-		muts = append(muts, &MergeQuest{q})
+		muts = append(muts, &MergeQuest{Quest: q})
 	}
 
 	return muts, datastore.Get(c).PutMulti(fwdDeps)