Function TestVectorDeadlockwithTimeout

query/vector/vector_test.go:529–569

(t *testing.T)

}

func TestVectorDeadlockwithTimeout(t *testing.T) {
	pred := "vtest1"
	dc = dgraphtest.NewComposeCluster()
	var cleanup func()
	client, cleanup, err := dc.Client()
	x.Panic(err)
	defer cleanup()

	for i := 0; i < 5; i++ {
		fmt.Println("Testing iteration: ", i)
		ctx, cancel2 := context.WithTimeout(context.Background(), 5*time.Second)
		defer cancel2()
		err = client.LoginIntoNamespace(ctx, dgraphapi.DefaultUser,
			dgraphapi.DefaultPassword, x.RootNamespace)
		require.NoError(t, err)

		err = client.Alter(context.Background(), &api.Operation{
			DropAttr: pred,
		})
		dropPredicate(pred)
		setSchema(fmt.Sprintf(vectorSchemaWithIndex, pred, "4", "euclidean"))
		numVectors := 10000
		vectorSize := 1000

		randomVectors, _ := generateRandomVectors(numVectors, vectorSize, pred)

		txn := client.NewTxn()
		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
		defer func() { _ = txn.Discard(ctx) }()
		defer cancel()

		_, err = txn.Mutate(ctx, &api.Mutation{
			SetNquads: []byte(randomVectors),
			CommitNow: true,
		})
		require.Error(t, err)

		err = txn.Commit(ctx)
		require.Contains(t, err.Error(), "Transaction has already been committed or discarded")
	}
}

func TestVectorMutateDiffrentLengthWithDiffrentIndexes(t *testing.T) {
	dropPredicate("vtest")