File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -528,7 +528,7 @@ func (mp *MutationPipeline) ProcessCount(ctx context.Context, pipeline *Predicat
528528 if updated {
529529 if ! info .isList {
530530 if ! info .noConflict {
531- // mp.txn.addConflictKey(farm.Fingerprint64(dataKey))
531+ mp .txn .addConflictKey (farm .Fingerprint64 (dataKey ))
532532 }
533533 } else {
534534 mp .txn .addConflictKeyWithUid (dataKey , postingList , info .hasUpsert , info .noConflict )
@@ -675,9 +675,9 @@ func (mp *MutationPipeline) ProcessSingle(ctx context.Context, pipeline *Predica
675675 binary .BigEndian .PutUint64 (dataKey [len (dataKey )- 8 :], uid )
676676 key := baseKey + string (dataKey [len (dataKey )- 8 :])
677677
678- if ! info .noConflict {
679- mp .txn .addConflictKey (farm .Fingerprint64 ([]byte (key )))
680- }
678+ // if !info.noConflict {
679+ // mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
680+ // }
681681
682682 if _ , err := mp .txn .AddDelta (key , * pl ); err != nil {
683683 return err
You can’t perform that action at this time.
0 commit comments