Skip to content

Commit d7ed07a

Browse files
committed
refactor: update replication tests to ListVerbose
1 parent 18cca2e commit d7ed07a

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/Weaviate.Client.Tests/Integration/TestReplication.cs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public async Task Test_Replicate_And_Get()
104104
// Retrieve node + shard info with retry (may lag right after creation)
105105
var nodes = await RetryAsync(async () =>
106106
{
107-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
107+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
108108
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
109109
{
110110
throw new InvalidOperationException("Shard info not yet available");
@@ -171,7 +171,7 @@ public async Task Test_Replicate_And_Cancel()
171171
await WaitForCollectionReady(collectionName);
172172
var nodes = await RetryAsync(async () =>
173173
{
174-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
174+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
175175
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
176176
{
177177
throw new InvalidOperationException("Shard info not yet available");
@@ -226,7 +226,7 @@ public async Task Test_Replicate_And_Delete()
226226
await WaitForCollectionReady(collectionName);
227227
var nodes = await RetryAsync(async () =>
228228
{
229-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
229+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
230230
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
231231
{
232232
throw new InvalidOperationException("Shard info not yet available");
@@ -293,7 +293,7 @@ public async Task Test_List_And_Query_Operations()
293293
await WaitForCollectionReady(collectionName);
294294
var nodes = await RetryAsync(async () =>
295295
{
296-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
296+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
297297
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
298298
{
299299
throw new InvalidOperationException("Shard info not yet available");
@@ -364,7 +364,7 @@ public async Task Test_DeleteAll_Operations()
364364
await WaitForCollectionReady(collectionName);
365365
var nodes = await RetryAsync(async () =>
366366
{
367-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
367+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
368368
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
369369
{
370370
throw new InvalidOperationException("Shard info not yet available");
@@ -426,7 +426,7 @@ public async Task Test_Wait_For_Successful_Completion()
426426
await WaitForCollectionReady(collectionName);
427427
var nodes = await RetryAsync(async () =>
428428
{
429-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
429+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
430430
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
431431
{
432432
throw new InvalidOperationException("Shard info not yet available");
@@ -485,7 +485,7 @@ public async Task Test_External_Cancellation_Detected_By_Tracker()
485485
await WaitForCollectionReady(collectionName);
486486
var nodes = await RetryAsync(async () =>
487487
{
488-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
488+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
489489
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
490490
{
491491
throw new InvalidOperationException("Shard info not yet available");
@@ -556,7 +556,7 @@ public async Task Test_Replication_Operation_Tracker_Properties()
556556
await WaitForCollectionReady(collectionName);
557557
var nodes = await RetryAsync(async () =>
558558
{
559-
var n = await _weaviate.Cluster.Nodes.NodesVerbose(collection: collectionName);
559+
var n = await _weaviate.Cluster.Nodes.ListVerbose(collection: collectionName);
560560
if (n.Length < 2 || n[0].Shards is null || n[0].Shards.Length == 0)
561561
{
562562
throw new InvalidOperationException("Shard info not yet available");

0 commit comments

Comments
 (0)