Skip to content

Commit 2aae765

Browse files
committed
add backlog hint logger
1 parent c3f8aea commit 2aae765

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

internal/internal_event_handlers.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ import (
4444

4545
const (
4646
queryResultSizeLimit = 2000000 // 2MB
47-
historySizeEstimationBuffer = 512 // 512B
47+
historySizeEstimationBuffer = 384 // 384B
4848
)
4949

5050
// Make sure that interfaces are implemented

internal/internal_task_pollers.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -811,6 +811,8 @@ func (wtp *workflowTaskPoller) poll(ctx context.Context) (interface{}, error) {
811811

812812
wtp.updateBacklog(request.TaskList.GetKind(), response.GetBacklogCountHint())
813813

814+
wtp.logger.Info(fmt.Sprintf("Tasklist backlog count is %d", response.GetBacklogCountHint()))
815+
814816
task := wtp.toWorkflowTask(response)
815817
traceLog(func() {
816818
var firstEventID int64 = -1

0 commit comments

Comments
 (0)