Initial distributor implementation

appengine/cmd/dm/mutate/ensure_quest_attempts.go

Index: appengine/cmd/dm/mutate/ensure_quest_attempts.go
diff --git a/appengine/cmd/dm/mutate/ensure_quest_attempts.go b/appengine/cmd/dm/mutate/ensure_quest_attempts.go
index 09479acf0515f87edcd7b9f00b211431c0a5ee96..2e5d902f153030fa1ea47684358a7469a6b42923 100644
--- a/appengine/cmd/dm/mutate/ensure_quest_attempts.go
+++ b/appengine/cmd/dm/mutate/ensure_quest_attempts.go
@@ -31,13 +31,13 @@ type EnsureQuestAttempts struct {
 
 // Root implements tumble.Mutation.
 func (e *EnsureQuestAttempts) Root(c context.Context) *datastore.Key {
-	return datastore.Get(c).KeyForObj(&model.Quest{ID: e.Quest.ID})
+	return model.QuestKeyFromID(c, e.Quest.ID)
 }
 
 // RollForward implements tumble.Mutation.
 func (e *EnsureQuestAttempts) RollForward(c context.Context) (muts []tumble.Mutation, err error) {
 	if !e.DoNotMergeQuest {
-		if _, err = (&MergeQuest{e.Quest}).RollForward(c); err != nil {
+		if _, err = (&MergeQuest{Quest: e.Quest}).RollForward(c); err != nil {
 			return
 		}
 	}