Initial distributor implementation

appengine/cmd/dm/mutate/record_completion_test.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package mutate
 
 import (
         "testing"
 
         "github.com/luci/gae/impl/memory"
@@ skipping 45 matching lines @@
 
                                 Convey("BDG exists, with unfinished deps", func() {
                                         bd := &model.BackDep{
                                                 Depender:      *dm.NewAttemptID("from", 1),
                                                 DependeeGroup: rc.Root(c),
                                         }
                                         So(ds.PutMulti([]interface{}{bdg, bd}), ShouldBeNil)
 
                                         muts, err := rc.RollForward(c)
                                         So(err, ShouldBeNil)
-                                        So(muts, ShouldResemble, []tumble.Mutation{
-                                                &AckFwdDep{Dep: bd.Edge(), DepIsFinished: true},
-                                        })
+                                        So(muts, ShouldResemble, []tumble.Mutation{&AckFwdDep{bd.Edge()}})
 
                                         So(ds.GetMulti([]interface{}{bdg, bd}), ShouldBeNil)
                                         So(bdg.AttemptFinished, ShouldBeTrue)
                                         So(bd.Propagated, ShouldBeTrue)
                                 })
 
                                 Convey("BDG exists, with finished deps", func() {
                                         bd := &model.BackDep{
                                                 Depender:      *dm.NewAttemptID("from", 1),
                                                 DependeeGroup: rc.Root(c),
@@ skipping 35 matching lines @@
                                         So(len(muts), ShouldEqual, amtWork-completionLimit)
 
                                         muts, err = rc.RollForward(c)
                                         So(err, ShouldBeNil)
                                         So(muts, ShouldBeEmpty)
                                 })
                         })
                 })
         })
 }