Index: appengine/cmd/dm/mutate/add_backdep.go |
diff --git a/appengine/cmd/dm/mutate/add_backdep.go b/appengine/cmd/dm/mutate/add_backdep.go |
index 2274a4d28178256280351c4e94a146339b7250f6..c86faab422570b1fee94a0b1cd2715e90c8b4e1d 100644 |
--- a/appengine/cmd/dm/mutate/add_backdep.go |
+++ b/appengine/cmd/dm/mutate/add_backdep.go |
@@ -43,11 +43,8 @@ func (a *AddBackDep) RollForward(c context.Context) (muts []tumble.Mutation, err |
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 |
} |