Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
- Update log level on AttachStream

## v0.9.0
- Writer client for YDB topics
- Fix: delete default timeout grpc.deadline
Expand Down
14 changes: 9 additions & 5 deletions src/Ydb.Sdk/src/Services/Query/SessionPool.cs
Original file line number Diff line number Diff line change
Expand Up @@ -74,27 +74,31 @@ protected override async Task<Session> CreateSession()
// ReSharper disable once InvertIf
if (!session.IsActive)
{
Logger.LogWarning("Session[{SessionId}] is deactivated", session.SessionId);
Logger.LogWarning("Session[{SessionId}] is deactivated. Reason: {Status}",
session.SessionId, sessionStateStatus);

return;
}
}

Logger.LogDebug("Session[{SessionId}]: Attached stream is closed", session.SessionId);

// attach stream is closed
}
catch (Driver.TransportException)
catch (Driver.TransportException e)
{
Logger.LogWarning(e, "Session[{SessionId}] is deactivated by transport error", session.SessionId);
}
}
catch (Exception e)
catch (Driver.TransportException e)
{
Logger.LogError(e, "Transport error on attach session");

completeTask.SetException(e);
}
finally
{
session.IsActive = false;

Logger.LogTrace("Session[{SessionId}]: Attached stream is closed", session.SessionId);
}
});

Expand Down
Loading