Skip to content

Commit 3f158af

Browse files
more fixes
1 parent ec42229 commit 3f158af

File tree

2 files changed

+7
-8
lines changed

2 files changed

+7
-8
lines changed

src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -166,16 +166,16 @@ private async Task Initialize()
166166

167167
if (RetrySettings.DefaultInstance.GetRetryRule(statusCode).Policy != RetryPolicy.None)
168168
{
169-
_logger.LogError("Reader initialization failed to start. Reason: {Status}", statusMessage);
169+
_logger.LogError("Reader initialization failed to start. {StatusMessage}", statusMessage);
170170

171171
_ = Task.Run(Initialize, _disposeCts.Token);
172172
}
173173
else
174174
{
175-
_logger.LogCritical("Reader initialization failed to start. Reason: {Status}", statusMessage);
175+
_logger.LogCritical("Reader initialization failed to start. {StatusMessage}", statusMessage);
176176

177177
_receivedMessagesChannel.Writer.Complete(
178-
new ReaderException($"Initialization failed! Reason: {statusMessage}"));
178+
new ReaderException($"Initialization failed! {statusMessage}"));
179179
}
180180

181181
return;
@@ -342,8 +342,7 @@ private async Task RunProcessingStreamResponse()
342342
}
343343
catch (Exception e)
344344
{
345-
Logger.LogError(e, "ReaderSession[{SessionId}] have error on processing server messages",
346-
SessionId);
345+
Logger.LogError(e, "ReaderSession[{SessionId}] have error on processing server messages", SessionId);
347346
}
348347
finally
349348
{

src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -241,15 +241,15 @@ private async Task Initialize()
241241

242242
if (RetrySettings.DefaultInstance.GetRetryRule(statusCode).Policy != RetryPolicy.None)
243243
{
244-
_logger.LogError("Writer initialization failed to start. Reason: {Status}", statusMessage);
244+
_logger.LogError("Writer initialization failed to start. {StatusMessage}", statusMessage);
245245

246246
_ = Task.Run(Initialize);
247247
}
248248
else
249249
{
250-
_logger.LogCritical("Writer initialization failed to start. Reason: {Status}", statusMessage);
250+
_logger.LogCritical("Writer initialization failed to start. {StatusMessage}", statusMessage);
251251

252-
_session = new NotStartedWriterSession($"Initialization failed! Reason: {statusMessage}");
252+
_session = new NotStartedWriterSession($"Initialization failed! {statusMessage}");
253253
}
254254

255255
return;

0 commit comments

Comments
 (0)