refactor(plugin): Rename executionArn to durableExecutionArn

Author: ayushiahjolia

examples/src/main/java/software/amazon/lambda/durable/examples/general/PluginExample.java

@@ -17,7 +17,7 @@
  * <p>Expected output for a successful run:
  *
  * <pre>
- * [PLUGIN] onInvocationStart: requestId=..., executionArn=..., firstInvocation=true
+ * [PLUGIN] onInvocationStart: requestId=..., durableExecutionArn=..., firstInvocation=true
  * [PLUGIN] onOperationStart: name=create-greeting, type=STEP
  * [PLUGIN] onUserFunctionStart: name=create-greeting, attempt=1
  * [PLUGIN] onUserFunctionEnd: name=create-greeting, succeeded=true
@@ -54,8 +54,8 @@ static class LoggingPlugin implements DurableExecutionPlugin {
         @Override
         public void onInvocationStart(InvocationInfo info) {
             System.out.printf(
-                    "[PLUGIN] onInvocationStart: requestId=%s, executionArn=%s, firstInvocation=%s%n",
-                    info.requestId(), info.executionArn(), info.isFirstInvocation());
+                    "[PLUGIN] onInvocationStart: requestId=%s, durableExecutionArn=%s, firstInvocation=%s%n",
+                    info.requestId(), info.durableExecutionArn(), info.isFirstInvocation());
         }
 
         @Override

otel-plugin/src/main/java/software/amazon/lambda/durable/otel/DeterministicIdGenerator.java

@@ -26,15 +26,15 @@ public class DeterministicIdGenerator implements IdGenerator {
 
     private final AtomicReference<String> executionTraceId = new AtomicReference<>(null);
     private final ThreadLocal<String> pendingSpanOperationId = new ThreadLocal<>();
-    private final AtomicReference<String> executionArn = new AtomicReference<>(null);
+    private final AtomicReference<String> durableExecutionArn = new AtomicReference<>(null);
 
     /**
      * Sets the execution ARN used for generating deterministic IDs.
      *
      * @param arn the durable execution ARN
      */
-    public void setExecutionArn(String arn) {
-        this.executionArn.set(arn);
+    public void setDurableExecutionArn(String arn) {
+        this.durableExecutionArn.set(arn);
         this.executionTraceId.set(generateTraceIdFromArn(arn));
     }
 
@@ -96,7 +96,7 @@ private String generateTraceIdFromArn(String arn) {
      * <p>Uses SHA-256 hash truncated to 16 hex chars (64 bits) for the span ID.
      */
     private String generateSpanIdFromOperation(String operationId) {
-        var arn = executionArn.get();
+        var arn = durableExecutionArn.get();
         var input = arn != null ? arn + ":" + operationId : operationId;
         var hash = sha256(input);
         // Span ID is 16 hex chars (8 bytes)

otel-plugin/src/main/java/software/amazon/lambda/durable/otel/MdcSpanEnricher.java

@@ -37,16 +37,16 @@ private MdcSpanEnricher() {}
     /**
      * Injects the current span's trace ID and span ID into MDC.
      *
-     * @param executionArn the durable execution ARN (may be null)
+     * @param durableExecutionArn the durable execution ARN (may be null)
      */
-    public static void inject(String executionArn) {
+    public static void inject(String durableExecutionArn) {
         var span = Span.current();
         if (span.getSpanContext().isValid()) {
             MDC.put(MDC_TRACE_ID, span.getSpanContext().getTraceId());
             MDC.put(MDC_SPAN_ID, span.getSpanContext().getSpanId());
         }
-        if (executionArn != null) {
-            MDC.put(MDC_EXECUTION_ARN, executionArn);
+        if (durableExecutionArn != null) {
+            MDC.put(MDC_EXECUTION_ARN, durableExecutionArn);
         }
     }
 

otel-plugin/src/main/java/software/amazon/lambda/durable/otel/OpenTelemetryDurablePlugin.java

@@ -60,7 +60,7 @@ public class OpenTelemetryDurablePlugin implements DurableExecutionPlugin {
 
     // Per-invocation state
     private volatile Span invocationSpan;
-    private volatile String executionArn;
+    private volatile String durableExecutionArn;
 
     // Thread-safe storage for operation spans (keyed by operationId) — open spans that need ending
     private final ConcurrentHashMap<String, Span> operationSpans = new ConcurrentHashMap<>();
@@ -116,16 +116,16 @@ public OpenTelemetryDurablePlugin(
 
     @Override
     public void onInvocationStart(InvocationInfo info) {
-        this.executionArn = info.executionArn();
-        idGenerator.setExecutionArn(info.executionArn());
+        this.durableExecutionArn = info.durableExecutionArn();
+        idGenerator.setDurableExecutionArn(info.durableExecutionArn());
 
         // Extract parent context from Lambda environment (X-Ray, W3C, etc.)
         var extractedParentContext = contextExtractor.extract();
 
         // Create invocation span as child of extracted context
         var spanBuilder = tracer.spanBuilder("durable.invocation")
                 .setParent(extractedParentContext)
-                .setAttribute(DURABLE_EXECUTION_ARN, info.executionArn())
+                .setAttribute(DURABLE_EXECUTION_ARN, info.durableExecutionArn())
                 .setAttribute(DURABLE_FIRST_INVOCATION, info.isFirstInvocation());
 
         if (info.requestId() != null) {
@@ -189,7 +189,7 @@ public void onOperationStart(OperationInfo info) {
 
         var spanBuilder = tracer.spanBuilder(spanName(info.type(), info.subType(), info.name()))
                 .setParent(parentContext)
-                .setAttribute(DURABLE_EXECUTION_ARN, executionArn)
+                .setAttribute(DURABLE_EXECUTION_ARN, durableExecutionArn)
                 .setAttribute(DURABLE_OPERATION_ID, info.id())
                 .setAttribute(DURABLE_OPERATION_TYPE, info.type());
 
@@ -239,7 +239,7 @@ public void onUserFunctionStart(UserFunctionStartInfo info) {
                 .setParent(parentContext)
                 .setStartTimestamp(info.startTimestamp() != null ? info.startTimestamp() : Instant.now());
 
-        spanBuilder.setAttribute(DURABLE_EXECUTION_ARN, executionArn);
+        spanBuilder.setAttribute(DURABLE_EXECUTION_ARN, durableExecutionArn);
         spanBuilder.setAttribute(DURABLE_OPERATION_ID, info.id());
 
         if (info.type() != null) {
@@ -261,7 +261,7 @@ public void onUserFunctionStart(UserFunctionStartInfo info) {
 
         // Inject trace context into MDC for log-trace correlation
         if (enableMdc) {
-            MdcSpanEnricher.inject(executionArn);
+            MdcSpanEnricher.inject(durableExecutionArn);
         }
     }
 

otel-plugin/src/test/java/software/amazon/lambda/durable/otel/DeterministicIdGeneratorTest.java

@@ -29,7 +29,7 @@ void generateTraceId_withoutArn_returnsRandom() {
 
     @Test
     void generateTraceId_withArn_returnsDeterministic() {
-        generator.setExecutionArn("arn:aws:lambda:us-east-1:123:function:test:$LATEST/durable/exec1");
+        generator.setDurableExecutionArn("arn:aws:lambda:us-east-1:123:function:test:$LATEST/durable/exec1");
 
         var id1 = generator.generateTraceId();
         var id2 = generator.generateTraceId();
@@ -40,10 +40,10 @@ void generateTraceId_withArn_returnsDeterministic() {
 
     @Test
     void generateTraceId_differentArns_produceDifferentIds() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
         var id1 = generator.generateTraceId();
 
-        generator.setExecutionArn("arn:exec2");
+        generator.setDurableExecutionArn("arn:exec2");
         var id2 = generator.generateTraceId();
 
         assertNotEquals(id1, id2);
@@ -60,7 +60,7 @@ void generateSpanId_withoutOperationId_returnsRandom() {
 
     @Test
     void generateSpanId_withOperationId_returnsDeterministic() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
         generator.setNextSpanOperationId("op-hash-1");
         var id1 = generator.generateSpanId();
 
@@ -73,7 +73,7 @@ void generateSpanId_withOperationId_returnsDeterministic() {
 
     @Test
     void generateSpanId_differentOperationIds_produceDifferentIds() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
 
         generator.setNextSpanOperationId("op-1");
         var id1 = generator.generateSpanId();
@@ -96,7 +96,7 @@ void generateSpanId_consumesPendingId() {
 
     @Test
     void generateSpanIdForOperation_doesNotConsumePending() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
         generator.setNextSpanOperationId("op-1");
 
         // This should NOT consume the pending
@@ -112,7 +112,7 @@ void generateSpanIdForOperation_doesNotConsumePending() {
 
     @Test
     void generateSpanIdForOperation_isDeterministic() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
 
         var id1 = generator.generateSpanIdForOperation("op-1");
         var id2 = generator.generateSpanIdForOperation("op-1");
@@ -122,15 +122,15 @@ void generateSpanIdForOperation_isDeterministic() {
 
     @Test
     void traceId_isValidHex() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
         var traceId = generator.generateTraceId();
 
         assertTrue(traceId.matches("[0-9a-f]{32}"), "Trace ID should be 32 hex chars: " + traceId);
     }
 
     @Test
     void spanId_isValidHex() {
-        generator.setExecutionArn("arn:exec1");
+        generator.setDurableExecutionArn("arn:exec1");
         generator.setNextSpanOperationId("op-1");
         var spanId = generator.generateSpanId();
 

sdk-integration-tests/src/test/java/software/amazon/lambda/durable/PluginIntegrationTest.java

@@ -39,7 +39,7 @@ void plugin_receivesInvocationStartAndEnd_onSuccessfulExecution() {
         // Verify invocation hooks fired
         assertEquals(1, plugin.invocationStarts.size());
         assertTrue(plugin.invocationStarts.get(0).isFirstInvocation());
-        assertNotNull(plugin.invocationStarts.get(0).executionArn());
+        assertNotNull(plugin.invocationStarts.get(0).durableExecutionArn());
 
         assertEquals(1, plugin.invocationEnds.size());
         assertEquals(InvocationStatus.SUCCEEDED, plugin.invocationEnds.get(0).invocationStatus());

sdk/src/main/java/software/amazon/lambda/durable/plugin/InvocationEndInfo.java

@@ -6,7 +6,7 @@
  * Information provided at the end of a Lambda invocation.
  *
  * @param requestId the Lambda request ID for this invocation
- * @param executionArn the durable execution ARN
+ * @param durableExecutionArn the durable execution ARN
  * @param isFirstInvocation true if this is the first invocation of the execution
  * @param invocationStatus the invocation outcome (SUCCEEDED, FAILED, or PENDING)
  * @param executionError non-null if the execution failed
@@ -15,7 +15,7 @@
 @Deprecated
 public record InvocationEndInfo(
         String requestId,
-        String executionArn,
+        String durableExecutionArn,
         boolean isFirstInvocation,
         InvocationStatus invocationStatus,
         Throwable executionError) {}

sdk/src/main/java/software/amazon/lambda/durable/plugin/InvocationInfo.java

@@ -6,9 +6,9 @@
  * Invocation-level information available to plugin hooks.
  *
  * @param requestId the Lambda request ID for this invocation
- * @param executionArn the durable execution ARN
+ * @param durableExecutionArn the durable execution ARN
  * @param isFirstInvocation true if this is the first invocation of the execution (not a replay invocation)
  * @deprecated This is a preview API that is experimental and may be changed or removed in future releases.
  */
 @Deprecated
-public record InvocationInfo(String requestId, String executionArn, boolean isFirstInvocation) {}
+public record InvocationInfo(String requestId, String durableExecutionArn, boolean isFirstInvocation) {}