Initial distributor implementation

appengine/cmd/dm/mutate/finish_attempt_test.go

Index: appengine/cmd/dm/mutate/finish_attempt_test.go
diff --git a/appengine/cmd/dm/mutate/finish_attempt_test.go b/appengine/cmd/dm/mutate/finish_attempt_test.go
index a834f5961866130033236f4500ea40cd91dad5d3..a9db6459f053c52f573f7435bff3cd51bef8673c 100644
--- a/appengine/cmd/dm/mutate/finish_attempt_test.go
+++ b/appengine/cmd/dm/mutate/finish_attempt_test.go
@@ -11,7 +11,7 @@ import (
 	"github.com/luci/gae/impl/memory"
 	"github.com/luci/gae/service/datastore"
 	"github.com/luci/luci-go/appengine/cmd/dm/model"
-	"github.com/luci/luci-go/appengine/tumble"
+	//"github.com/luci/luci-go/appengine/tumble"
 	"github.com/luci/luci-go/common/api/dm/service/v1"
 	"github.com/luci/luci-go/common/clock/testclock"
 	. "github.com/luci/luci-go/common/testing/assertions"
@@ -55,12 +55,10 @@ func TestFinishAttempt(t *testing.T) {
 			Convey("Good", func() {
 				muts, err := fa.RollForward(c)
 				So(err, ShouldBeNil)
-				So(muts, ShouldResemble, []tumble.Mutation{
-					&RecordCompletion{For: &a.ID}})
+				So(muts, ShouldBeEmpty)
 
 				So(ds.GetMulti([]interface{}{a, e, ar}), ShouldBeNil)
 				So(e.Token, ShouldBeEmpty)
-				So(a.State, ShouldEqual, dm.Attempt_FINISHED)
 				So(a.ResultExpiration, ShouldResemble,
 					testclock.TestTimeUTC.Round(time.Microsecond))
 				So(ar.Data, ShouldResemble, `{"result": true}`)