Skip to content

Commit 1e4ad83

Browse files
fix error message
1 parent 30ac3b8 commit 1e4ad83

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

src/Ydb.Sdk/test/Ydb.Sdk.Topic.Tests/ReaderUnitTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -375,9 +375,9 @@ public async Task Initialize_WhenInitResponseStatusIsNotRetryable_ShouldThrowRea
375375
SubscribeSettings = { new SubscribeSettings("/topic") }
376376
}.Build();
377377

378-
Assert.Equal("Initialization failed: Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
378+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
379379
(await Assert.ThrowsAsync<ReaderException>(async () => await reader.ReadAsync())).Message);
380-
Assert.Equal("Initialization failed: Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
380+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
381381
(await Assert.ThrowsAsync<ReaderException>(async () => await reader.ReadBatchAsync())).Message);
382382

383383
_mockStream.Verify(stream => stream.Write(It.Is<FromClient>(msg =>

src/Ydb.Sdk/test/Ydb.Sdk.Topic.Tests/WriterIntegrationTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public async Task WriteAsync_WhenTopicNotFound_ReturnNotFoundException()
3939
{ ProducerId = "producerId" }.Build();
4040

4141
Assert.Contains(
42-
$"Initialization failed: Status: SchemeError, Issues:\n[500017] Error: no path 'local/{_topicName + "_not_found"}'",
42+
$"Initialization failed! Status: SchemeError, Issues:\n[500017] Error: no path 'local/{_topicName + "_not_found"}'",
4343
(await Assert.ThrowsAsync<WriterException>(() => writer.WriteAsync("hello world"))).Message
4444
);
4545
}

src/Ydb.Sdk/test/Ydb.Sdk.Topic.Tests/WriterUnitTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -295,9 +295,9 @@ public async Task
295295
await using var writer = new WriterBuilder<long>(_mockIDriver.Object, "/topic-6")
296296
{ ProducerId = "producerId" }.Build();
297297

298-
Assert.Equal("Initialization failed: Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
298+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
299299
(await Assert.ThrowsAsync<WriterException>(() => writer.WriteAsync(123L))).Message);
300-
Assert.Equal("Initialization failed: Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
300+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
301301
(await Assert.ThrowsAsync<WriterException>(() => writer.WriteAsync(1L))).Message);
302302

303303
// check not attempt repeated!!!

0 commit comments

Comments
 (0)