refactor(plugin): create one plugin instance per invocation

.github/lambda-layer-publish.toml

@@ -1,2 +1,2 @@
 [layer]
-sdk-version = "2.0.0"
+sdk-version = "3.0.0"

packages/aws-durable-execution-sdk-python-conformance-tests-otel/README.md

@@ -35,9 +35,9 @@ tests/                      # contract tests for the templates and handlers
 
 The 20 invocation and 20 execution requirements reuse the same scenario
 handlers; the view is selected per function through the `OTEL_PLUGIN_MODE`
-environment variable, which `common.otel_plugin()` reads to pick
-`InvocationOtelPlugin` or `ExecutionOtelPlugin`. `template.yaml` deploys only the
-view named by its `OtelSuite` parameter.
+environment variable, which `common.otel_plugin_factory()` reads to pick
+`InvocationOtelPluginFactory` or `ExecutionOtelPluginFactory`. `template.yaml`
+deploys only the view named by its `OtelSuite` parameter.
 
 ## Scenarios
 
@@ -182,8 +182,9 @@ write access; the runner identity needs list, read, and cleanup access.
 1. Find or add the requirement in the conformance repository under
    `test-requirements/<suite>/<id>.yaml`. New requirement IDs must be registered
    there first.
-2. Add `src/otel_<n>_<name>.py` exporting `handler`. Select the plugin with
-   `common.otel_plugin()` and guard the input with `common.require_scenario()`.
+2. Add `src/otel_<n>_<name>.py` exporting `handler`. Select the plugin factory
+   with `common.otel_plugin_factory()` and guard the input with
+   `common.require_scenario()`.
    Use the SDK's real API; never hand-roll behavior to force an expected result.
 3. Register the function in `template.yaml` (or `template-long-running.yaml`)
    with `Handler: <module>.handler` and `TestDescription: ["<id>"]`, and add a

packages/aws-durable-execution-sdk-python-conformance-tests-otel/pyproject.toml

@@ -8,8 +8,8 @@ version = "0.0.0"
 description = "OpenTelemetry conformance test handlers for the AWS Durable Execution SDK for Python, exercised by the aws-durable-execution-conformance-tests OTel suites."
 requires-python = ">=3.11"
 dependencies = [
-  "aws-durable-execution-sdk-python==2.0.1",
-  "aws-durable-execution-sdk-python-otel==1.0.0",
+  "aws-durable-execution-sdk-python==3.0.0",
+  "aws-durable-execution-sdk-python-otel==2.0.0",
 ]
 
 [tool.hatch.build.targets.wheel]

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/common.py

@@ -9,20 +9,28 @@
 from collections.abc import Mapping
 from typing import Any
 
-from aws_durable_execution_sdk_python.plugin import DurableInstrumentationPlugin
+from aws_durable_execution_sdk_python.plugin import (
+    DurableInstrumentationPluginFactory,
+)
 from aws_durable_execution_sdk_python_otel import (
-    ExecutionOtelPlugin,
-    InvocationOtelPlugin,
+    ExecutionOtelPluginFactory,
+    InvocationOtelPluginFactory,
     OtelPluginConfig,
 )
 
 
-def otel_plugin() -> DurableInstrumentationPlugin:
-    """Select the telemetry view configured for this deployed function."""
+def otel_plugin_factory() -> DurableInstrumentationPluginFactory:
+    """Select the telemetry view configured for this deployed function.
+
+    Returns a factory, which is what ``durable_execution(plugins=[...])`` takes:
+    the SDK calls its ``create_plugin`` once per invocation to build that
+    invocation's plugin. The view is still resolved once, when the handler module
+    is imported.
+    """
 
     if os.environ.get("OTEL_PLUGIN_MODE") == "execution":
-        return ExecutionOtelPlugin(OtelPluginConfig())
-    return InvocationOtelPlugin(OtelPluginConfig())
+        return ExecutionOtelPluginFactory(OtelPluginConfig())
+    return InvocationOtelPluginFactory(OtelPluginConfig())
 
 
 def require_scenario(event: Mapping[str, Any], expected: str) -> None:

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_10_wait_for_callback.py

@@ -9,7 +9,7 @@
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
 from aws_durable_execution_sdk_python.types import WaitForCallbackContext
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 def submit_callback(
@@ -19,7 +19,7 @@ def submit_callback(
     return None
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> str:
     require_scenario(event, "wait-for-callback")
     return context.wait_for_callback(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_11_chained_invoke.py

@@ -9,10 +9,10 @@
 from typing import Any
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(
     event: dict[str, Any],
     context: DurableContext,
@@ -25,7 +25,7 @@ def handler(
     )
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def target_handler(
     event: dict[str, Any],
     _context: DurableContext,

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_12_child_context_failure.py

@@ -12,15 +12,15 @@
     durable_execution,
     durable_with_child_context,
 )
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_with_child_context
 def fail_child_context(_context: DurableContext) -> None:
     raise RuntimeError("Intentional child-context failure")
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "child-context-failure")
     context.run_in_child_context(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_13_parallel_failure.py

@@ -13,15 +13,15 @@
     durable_parallel_branch,
 )
 from aws_durable_execution_sdk_python.config import ParallelConfig
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_parallel_branch(name="otel-failed-parallel-branch")
 def fail_parallel_branch(_context: DurableContext) -> None:
     raise RuntimeError("Intentional parallel branch failure")
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "parallel-failure")
     result = context.parallel(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_14_map_failure.py

@@ -10,7 +10,7 @@
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
 from aws_durable_execution_sdk_python.config import MapConfig
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 def fail_map_item(
@@ -22,7 +22,7 @@ def fail_map_item(
     raise RuntimeError("Intentional map iteration failure")
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "map-failure")
     result = context.map(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_15_wait_interrupted.py

@@ -9,10 +9,10 @@
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
 from aws_durable_execution_sdk_python.config import Duration
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "wait-interrupted")
     context.wait(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_16_wait_for_condition_failure.py

@@ -14,7 +14,7 @@
     WaitForConditionConfig,
     WaitForConditionDecision,
 )
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 def fail_condition_check(
@@ -31,7 +31,7 @@ def continue_condition(
     return WaitForConditionDecision.continue_waiting(Duration.from_seconds(1))
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "wait-for-condition-failure")
     context.wait_for_condition(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_17_wait_for_callback_failure.py

@@ -9,7 +9,7 @@
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
 from aws_durable_execution_sdk_python.types import WaitForCallbackContext
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 def submit_failed_callback(
@@ -19,7 +19,7 @@ def submit_failed_callback(
     return None
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "wait-for-callback-failure")
     context.wait_for_callback(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_18_chained_invoke_failure.py

@@ -9,10 +9,10 @@
 from typing import Any
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "chained-invoke-failure")
     context.invoke(
@@ -22,7 +22,7 @@ def handler(event: dict[str, Any], context: DurableContext) -> None:
     )
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def target_handler(
     _event: dict[str, Any],
     _context: DurableContext,

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_19_execution_failure.py

@@ -8,10 +8,10 @@
 from typing import Any
 
 from aws_durable_execution_sdk_python import DurableContext, durable_execution
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], _context: DurableContext) -> None:
     require_scenario(event, "execution-failure")
     raise RuntimeError("Intentional execution failure")

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_1_success.py

@@ -13,15 +13,15 @@
     durable_execution,
     durable_step,
 )
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
 def complete_successfully(_step_context: StepContext) -> str:
     return "success"
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> str:
     require_scenario(event, "success")
     return context.step(complete_successfully(), name="otel-success")

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_20_virtual_context.py

@@ -13,15 +13,15 @@
     durable_with_child_context,
 )
 from aws_durable_execution_sdk_python.config import ChildConfig
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_with_child_context
 def run_virtual_context(_context: DurableContext) -> str:
     return "virtual-complete"
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> str:
     require_scenario(event, "virtual-context")
     return context.run_in_child_context(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_2_wait_resume.py

@@ -14,15 +14,15 @@
     durable_step,
 )
 from aws_durable_execution_sdk_python.config import Duration
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
 def complete_after_resume(_step_context: StepContext) -> str:
     return "resumed"
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> str:
     require_scenario(event, "wait-resume")
     context.wait(Duration.from_seconds(1), name="otel-wait")

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_3_retry.py

@@ -18,7 +18,7 @@
     RetryStrategyConfig,
     create_retry_strategy,
 )
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
@@ -28,7 +28,7 @@ def succeed_on_retry(step_context: StepContext) -> str:
     return "retried"
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> str:
     require_scenario(event, "retry")
     retry_strategy = create_retry_strategy(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_4_terminal_failure.py

@@ -18,15 +18,15 @@
     RetryStrategyConfig,
     create_retry_strategy,
 )
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
 def fail_terminally(_step_context: StepContext) -> None:
     raise RuntimeError("Intentional terminal failure")
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> None:
     require_scenario(event, "terminal-failure")
     retry_strategy = create_retry_strategy(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_5_child_context.py

@@ -14,7 +14,7 @@
     durable_step,
     durable_with_child_context,
 )
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
@@ -27,7 +27,7 @@ def run_child_workflow(context: DurableContext) -> str:
     return context.step(complete_child_step(), name="otel-child-step")
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> str:
     require_scenario(event, "child-context")
     return context.run_in_child_context(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_6_parallel.py

@@ -15,7 +15,7 @@
     durable_step,
 )
 from aws_durable_execution_sdk_python.config import ParallelConfig
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
@@ -39,7 +39,7 @@ def run_parallel_branch_b(context: DurableContext) -> str:
     )
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> list[str]:
     require_scenario(event, "parallel-hierarchy")
     return context.parallel(

packages/aws-durable-execution-sdk-python-conformance-tests-otel/src/otel_7_map.py

@@ -15,7 +15,7 @@
     durable_step,
 )
 from aws_durable_execution_sdk_python.config import MapConfig
-from common import otel_plugin, require_scenario
+from common import otel_plugin_factory, require_scenario
 
 
 @durable_step
@@ -35,7 +35,7 @@ def process_map_item(
     )
 
 
-@durable_execution(plugins=[otel_plugin()])
+@durable_execution(plugins=[otel_plugin_factory()])
 def handler(event: dict[str, Any], context: DurableContext) -> list[int]:
     require_scenario(event, "map-hierarchy")
     return context.map(