Skip to content

Commit f362e64

Browse files
committed
fix: creating a table only possible against databases
1 parent adac885 commit f362e64

File tree

1 file changed

+16
-10
lines changed

1 file changed

+16
-10
lines changed

tests/e2e/smoke_test.go

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -473,20 +473,26 @@ var _ = Describe("Operator smoke test", func() {
473473
By("checking that all the database pods are running and ready...")
474474
CheckPodsRunningAndReady(ctx, k8sClient, "ydb-cluster", "kind-database", databaseSample.Spec.Nodes)
475475

476-
storagePods := corev1.PodList{}
477-
Expect(k8sClient.List(ctx, &storagePods,
476+
database := v1alpha1.Database{}
477+
Expect(k8sClient.Get(ctx, types.NamespacedName{
478+
Name: databaseSample.Name,
479+
Namespace: testobjects.YdbNamespace,
480+
}, &database)).Should(Succeed())
481+
storageEndpoint := database.Spec.StorageEndpoint
482+
483+
databasePods := corev1.PodList{}
484+
Expect(k8sClient.List(ctx, &databasePods,
478485
client.InNamespace(testobjects.YdbNamespace),
479-
client.MatchingLabels{
480-
"ydb-cluster": "kind-database",
481-
})).Should(Succeed())
482-
podName := storagePods.Items[0].Name
486+
client.MatchingLabels{"ydb-cluster": "kind-database"}),
487+
).Should(Succeed())
488+
podName := databasePods.Items[0].Name
483489

484-
By("bring YDB CLI inside ydb storage pod...")
490+
By("bring YDB CLI inside ydb database pod...")
485491
BringYdbCliToPod(podName, testobjects.YdbNamespace)
486492

487-
By("execute simple query inside ydb storage pod...")
488-
storageEndpoint := fmt.Sprintf("grpcs://%s:%d", testobjects.StorageGRPCService, testobjects.StorageGRPCPort)
489-
ExecuteSimpleTableE2ETest(podName, testobjects.YdbNamespace, storageEndpoint, "/"+testobjects.DefaultDomain)
493+
By("execute simple query inside ydb database pod...")
494+
databasePath := DatabasePathWithDefaultDomain(databaseSample)
495+
ExecuteSimpleTableE2ETest(podName, testobjects.YdbNamespace, storageEndpoint, databasePath)
490496
})
491497

492498
It("Check that Storage deleted after Database...", func() {

0 commit comments

Comments
 (0)