Log error when fetchHistoryFromRemote fails (uber#4807)

lindleywhite · Apr 27, 2022 · 22f97c8 · 22f97c8
1 parent e91a5a7
commit 22f97c8
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/service/history/task/transfer_standby_task_executor.go b/service/history/task/transfer_standby_task_executor.go
@@ -606,7 +606,7 @@ func (t *transferStandbyTaskExecutor) fetchHistoryFromRemote(
 	_ context.Context,
 	taskInfo Info,
 	postActionInfo interface{},
-	log log.Logger,
+	_ log.Logger,
 ) error {
 
 	if postActionInfo == nil {
@@ -645,7 +645,9 @@ func (t *transferStandbyTaskExecutor) fetchHistoryFromRemote(
 			tag.WorkflowDomainID(transferTask.DomainID),
 			tag.WorkflowID(transferTask.WorkflowID),
 			tag.WorkflowRunID(transferTask.RunID),
-			tag.SourceCluster(t.clusterName))
+			tag.SourceCluster(t.clusterName),
+			tag.Error(err),
+		)
 	}
 
 	// return error so task processing logic will retry