Initial distributor implementation

appengine/cmd/dm/mutate/add_backdep.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 (
         "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/appengine/cmd/dm/model"
         "github.com/luci/luci-go/appengine/tumble"
@@ skipping 25 matching lines @@
                 err = ds.Put(bdg)
         }
         if err != nil {
                 return
         }
 
         bd.Propagated = bdg.AttemptFinished
 
         err = ds.Put(bd)
 
-        if a.NeedsAck {
-                muts = append(muts, &AckFwdDep{
-                        Dep:           a.Dep,
-                        DepIsFinished: bdg.AttemptFinished,
-                })
+        if a.NeedsAck && bdg.AttemptFinished {
+                muts = append(muts, &AckFwdDep{a.Dep})
         }
         return
 }
 
 func init() {
         tumble.Register((*AddBackDep)(nil))
 }