From 1a3a52245236a29de5577651ea8c6e4ce485921f Mon Sep 17 00:00:00 2001 From: Evan Sandoval Date: Wed, 13 Aug 2025 10:08:26 -0700 Subject: [PATCH] Add attempt number to structured activity logger --- src/main/java/com/uber/cadence/internal/logging/LoggerTag.java | 1 + .../java/com/uber/cadence/internal/worker/ActivityWorker.java | 2 ++ 2 files changed, 3 insertions(+) diff --git a/src/main/java/com/uber/cadence/internal/logging/LoggerTag.java b/src/main/java/com/uber/cadence/internal/logging/LoggerTag.java index f31c0fbe4..cdd3aa2dd 100644 --- a/src/main/java/com/uber/cadence/internal/logging/LoggerTag.java +++ b/src/main/java/com/uber/cadence/internal/logging/LoggerTag.java @@ -25,4 +25,5 @@ public class LoggerTag { public static final String TASK_LIST = "TaskList"; public static final String WORKFLOW_ID = "WorkflowID"; public static final String WORKFLOW_TYPE = "WorkflowType"; + public static final String ATTEMPT = "Attempt"; } diff --git a/src/main/java/com/uber/cadence/internal/worker/ActivityWorker.java b/src/main/java/com/uber/cadence/internal/worker/ActivityWorker.java index 9e83156d5..767f63ea1 100644 --- a/src/main/java/com/uber/cadence/internal/worker/ActivityWorker.java +++ b/src/main/java/com/uber/cadence/internal/worker/ActivityWorker.java @@ -144,6 +144,7 @@ public void handle(PollForActivityTaskResponse task) throws Exception { MDC.put(LoggerTag.ACTIVITY_TYPE, task.getActivityType().getName()); MDC.put(LoggerTag.WORKFLOW_ID, task.getWorkflowExecution().getWorkflowId()); MDC.put(LoggerTag.RUN_ID, task.getWorkflowExecution().getRunId()); + MDC.put(LoggerTag.ATTEMPT, String.valueOf(task.getAttempt())); propagateContext(task); Span span = spanFactory.spanForExecuteActivity(task); @@ -175,6 +176,7 @@ public void handle(PollForActivityTaskResponse task) throws Exception { MDC.remove(LoggerTag.ACTIVITY_TYPE); MDC.remove(LoggerTag.WORKFLOW_ID); MDC.remove(LoggerTag.RUN_ID); + MDC.remove(LoggerTag.ATTEMPT); unsetCurrentContext(); } }