Skip to content

Commit

Permalink
Remove ignore index conflict from various places (#3854)
Browse files Browse the repository at this point in the history
  • Loading branch information
mangalaman93 authored Aug 23, 2019
1 parent e3660d4 commit 8163f0a
Show file tree
Hide file tree
Showing 7 changed files with 304 additions and 357 deletions.
10 changes: 5 additions & 5 deletions dgraph/cmd/alpha/http_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -158,8 +158,8 @@ func queryWithTs(queryText, contentType, debug string, ts uint64) (string, uint6
return string(output), startTs, err
}

func mutationWithTs(m, t string, isJson bool, commitNow bool, ignoreIndexConflict bool,
ts uint64) ([]string, []string, uint64, error) {
func mutationWithTs(m, t string, isJson bool, commitNow bool, ts uint64) (
[]string, []string, uint64, error) {

params := make([]string, 2)
if ts != 0 {
Expand Down Expand Up @@ -313,7 +313,7 @@ func TestTransactionBasic(t *testing.T) {
}
`

keys, preds, mts, err := mutationWithTs(m1, "application/rdf", false, false, true, ts)
keys, preds, mts, err := mutationWithTs(m1, "application/rdf", false, false, ts)
require.NoError(t, err)
require.Equal(t, mts, ts)
require.Equal(t, 4, len(keys))
Expand Down Expand Up @@ -367,7 +367,7 @@ func TestTransactionBasicNoPreds(t *testing.T) {
}
`

keys, _, mts, err := mutationWithTs(m1, "application/rdf", false, false, true, ts)
keys, _, mts, err := mutationWithTs(m1, "application/rdf", false, false, ts)
require.NoError(t, err)
require.Equal(t, mts, ts)
require.Equal(t, 4, len(keys))
Expand Down Expand Up @@ -413,7 +413,7 @@ func TestTransactionBasicOldCommitFormat(t *testing.T) {
}
`

keys, _, mts, err := mutationWithTs(m1, "application/rdf", false, false, true, ts)
keys, _, mts, err := mutationWithTs(m1, "application/rdf", false, false, ts)
require.NoError(t, err)
require.Equal(t, mts, ts)
require.Equal(t, 4, len(keys))
Expand Down
4 changes: 2 additions & 2 deletions dgraph/cmd/alpha/run_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -133,12 +133,12 @@ func runJSONQuery(q string) (string, error) {
}

func runMutation(m string) error {
_, _, _, err := mutationWithTs(m, "application/rdf", false, true, false, 0)
_, _, _, err := mutationWithTs(m, "application/rdf", false, true, 0)
return err
}

func runJSONMutation(m string) error {
_, _, _, err := mutationWithTs(m, "application/json", true, true, false, 0)
_, _, _, err := mutationWithTs(m, "application/json", true, true, 0)
return err
}

Expand Down
Loading

0 comments on commit 8163f0a

Please sign in to comment.