some fixes

worker/groups.go

@@ -671,7 +671,7 @@ func (g *groupi) proposeDelta(oracleDelta *intern.OracleDelta) {
 	}
 
 	repeat := func(tctx *api.TxnContext) {
-		for i := 0; i < 3; i++ { // Try 3 times, then give up.
+		for i := 0; i < 1; i++ {
 			// TODO: This needs to be looked at carefully to figure out why does this fail.
 			err := g.Node.proposeAndWait(context.Background(), &intern.Proposal{TxnContext: tctx})
 			if err == nil {

worker/mutation.go

@@ -40,6 +40,9 @@ func deletePredicateEdge(edge *intern.DirectedEdge) bool {
 
 // runMutation goes through all the edges and applies them.
 func runMutation(ctx context.Context, edge *intern.DirectedEdge, txn *posting.Txn) error {
+	if ctx.Err() != nil {
+		return ctx.Err()
+	}
 	if tr, ok := trace.FromContext(ctx); ok {
 		tr.LazyPrintf("%s", "In run mutations")
 	}