Add domain name and tasklist tags to logs

uber · Mar 5, 2024 · e3ca207 · e3ca207
1 parent dcb4be7
commit e3ca207
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/service/frontend/api/handler.go b/service/frontend/api/handler.go
@@ -430,7 +430,7 @@ func (wh *WorkflowHandler) PollForActivityTask(
  if err := common.ValidateLongPollContextTimeout(
  ctx,
  "PollForActivityTask",
- wh.GetThrottledLogger(),
+ wh.GetThrottledLogger().WithTags(tag.WorkflowDomainName(domainName), tag.WorkflowTaskListName(pollRequest.GetTaskList().GetName())),
  ); err != nil {
  return nil, err
  }
@@ -478,7 +478,7 @@ func (wh *WorkflowHandler) PollForActivityTask(
  if err := common.ValidateLongPollContextTimeout(
  ctx,
  "PollForActivityTask",
- wh.GetThrottledLogger(),
+ wh.GetThrottledLogger().WithTags(tag.WorkflowDomainName(domainName), tag.WorkflowTaskListName(pollRequest.GetTaskList().GetName())),
  ); err != nil {
  return &types.PollForActivityTaskResponse{}, nil
  }
@@ -544,7 +544,7 @@ func (wh *WorkflowHandler) PollForDecisionTask(
  if err := common.ValidateLongPollContextTimeout(
  ctx,
  "PollForDecisionTask",
- wh.GetThrottledLogger(),
+ wh.GetThrottledLogger().WithTags(tag.WorkflowDomainName(domainName), tag.WorkflowTaskListName(pollRequest.GetTaskList().GetName())),
  ); err != nil {
  return nil, err
  }
@@ -598,7 +598,7 @@ func (wh *WorkflowHandler) PollForDecisionTask(
  if err := common.ValidateLongPollContextTimeout(
  ctx,
  "PollForDecisionTask",
- wh.GetThrottledLogger(),
+ wh.GetThrottledLogger().WithTags(tag.WorkflowDomainName(domainName), tag.WorkflowTaskListName(pollRequest.GetTaskList().GetName())),
  ); err != nil {
  return &types.PollForDecisionTaskResponse{}, nil
  }