Skip to content

Commit f4968f1

Browse files
authored
Merge pull request #1420 from ydb-platform/improve-topic-log
Fixed log messages for send nessage to topic
2 parents c93c91c + 48a5e12 commit f4968f1

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
* Changed log message about send topic message
12
* Added experimental support for executing scripts over query service client (`query.Client.ExecuteScript` and `query.CLient.FetchScriptResults`)
23
* Removed tx result from `query.Session.Execute` (tx can be obtained from `query.Session.Begin`)
34
* Changed behaviour of `query.Session.Begin` to `noop` for lazy initialization with first call `query.TxActor.Execute`

log/topic.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -799,7 +799,7 @@ func internalTopic(l Logger, d trace.Detailer) (t trace.Topic) {
799799

800800
return func(doneInfo trace.TopicWriterSendMessagesDoneInfo) {
801801
if doneInfo.Error == nil {
802-
l.Log(ctx, "send messages completed",
802+
l.Log(ctx, "writing messages to grpc buffer completed",
803803
String("writer_instance_id", info.WriterInstanceID),
804804
String("session_id", info.SessionID),
805805
Any("codec", info.Codec),
@@ -808,7 +808,7 @@ func internalTopic(l Logger, d trace.Detailer) (t trace.Topic) {
808808
latencyField(start),
809809
)
810810
} else {
811-
l.Log(WithLevel(ctx, WARN), "send messages completed",
811+
l.Log(WithLevel(ctx, WARN), "writing messages to grpc buffer completed",
812812
Error(doneInfo.Error),
813813
String("writer_instance_id", info.WriterInstanceID),
814814
String("session_id", info.SessionID),

0 commit comments

Comments
 (0)