Add debug logging for activity retrytimer

temporalio · Sep 14, 2022 · 9f7c100 · 9f7c100
1 parent 81a92f1
commit 9f7c100
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/service/history/timerQueueActiveTaskExecutor.go b/service/history/timerQueueActiveTaskExecutor.go
@@ -390,6 +390,16 @@ func (t *timerQueueActiveTaskExecutor) executeActivityRetryTimerTask(
 	ctx context.Context,
 	task *tasks.ActivityRetryTimerTask,
 ) (retError error) {
+
+	t.logger.Info("Executing activity retry timer task",
+		tag.WorkflowID(task.GetWorkflowID()),
+		tag.WorkflowRunID(task.GetRunID()),
+		tag.WorkflowNamespaceID(task.GetNamespaceID()),
+		tag.WorkflowScheduledEventID(task.EventID),
+		tag.FailoverVersion(task.Version),
+		tag.ScheduleAttempt(task.Attempt),
+	)
+
 	ctx, cancel := context.WithTimeout(ctx, taskTimeout)
 	defer cancel()
 

diff --git a/service/history/workflow/mutable_state_impl.go b/service/history/workflow/mutable_state_impl.go
@@ -3740,6 +3740,14 @@ func (e *MutableStateImpl) RetryActivity(
 	ai.RetryLastWorkerIdentity = ai.StartedIdentity
 	ai.RetryLastFailure = failure
 
+	e.logger.Info("Generating activity retry timer task",
+		tag.WorkflowID(e.executionInfo.WorkflowId),
+		tag.WorkflowRunID(e.executionState.RunId),
+		tag.WorkflowNamespaceID(e.executionInfo.NamespaceId),
+		tag.WorkflowScheduledEventID(ai.ScheduledEventId),
+		tag.ScheduleAttempt(ai.Attempt),
+	)
+
 	if err := e.taskGenerator.GenerateActivityRetryTasks(
 		ai.ScheduledEventId,
 	); err != nil {