Apm ai toolkit/new integration/aws durable execution sdk python/20260415 022329

.riot/requirements/176b83f.txt

@@ -0,0 +1,27 @@
+#
+# This file is autogenerated by pip-compile with Python 3.12
+# by the following command:
+#
+#    pip-compile --allow-unsafe --no-annotate .riot/requirements/176b83f.in
+#
+attrs==26.1.0
+aws-durable-execution-sdk-python==1.4.0
+boto3==1.42.89
+botocore==1.42.89
+coverage[toml]==7.13.5
+hypothesis==6.45.0
+iniconfig==2.3.0
+jmespath==1.1.0
+mock==5.2.0
+opentracing==2.4.0
+packaging==26.1
+pluggy==1.6.0
+pygments==2.20.0
+pytest==9.0.3
+pytest-cov==7.1.0
+pytest-mock==3.15.1
+python-dateutil==2.9.0.post0
+s3transfer==0.16.0
+six==1.17.0
+sortedcontainers==2.4.0
+urllib3==2.6.3

.riot/requirements/9211a02.txt

@@ -0,0 +1,27 @@
+#
+# This file is autogenerated by pip-compile with Python 3.13
+# by the following command:
+#
+#    pip-compile --allow-unsafe --no-annotate .riot/requirements/9211a02.in
+#
+attrs==26.1.0
+aws-durable-execution-sdk-python==1.4.0
+boto3==1.42.89
+botocore==1.42.89
+coverage[toml]==7.13.5
+hypothesis==6.45.0
+iniconfig==2.3.0
+jmespath==1.1.0
+mock==5.2.0
+opentracing==2.4.0
+packaging==26.1
+pluggy==1.6.0
+pygments==2.20.0
+pytest==9.0.3
+pytest-cov==7.1.0
+pytest-mock==3.15.1
+python-dateutil==2.9.0.post0
+s3transfer==0.16.0
+six==1.17.0
+sortedcontainers==2.4.0
+urllib3==2.6.3

ddtrace/_monkey.py

@@ -95,6 +95,7 @@
     "dogpile_cache": True,
     "yaaredis": True,
     "asyncpg": True,
+    "aws_durable_execution_sdk_python": True,
     "aws_lambda": True,  # patch only in AWS Lambda environments
     "azure_cosmos": True,
     "azure_eventhubs": True,

ddtrace/contrib/internal/aws_durable_execution_sdk_python/__init__.py

@@ -0,0 +1,53 @@
+"""
+The AWS Durable Execution SDK integration instruments the
+``aws-durable-execution-sdk-python`` library to trace durable workflow
+executions, step executions, and cross-function invocations.
+
+All traces submitted from this integration are tagged by:
+
+- ``service``, ``env``, ``version``: see the `Unified Service Tagging docs
+  <https://docs.datadoghq.com/getting_started/tagging/unified_service_tagging>`_.
+- ``aws.durable_execution.arn``: The ARN of the durable execution.
+- ``aws.durable_execution.replay_status``: Whether the execution is NEW or REPLAY.
+- ``aws.durable_execution.step.name``: The name of the step being executed.
+- ``aws.durable_execution.step.replayed``: Whether the step was replayed from checkpoint (``"true"``) or executed fresh (``"false"``).
+- ``aws.durable_execution.invoke.function_name``: The target function name for invoke calls.
+
+
+Enabling
+~~~~~~~~
+
+The AWS Durable Execution SDK integration is enabled automatically when you use
+:ref:`ddtrace-run<ddtracerun>` or :ref:`import ddtrace.auto<ddtraceauto>`.
+
+Alternatively, use :func:`patch() <ddtrace.patch>` to manually enable the integration::
+
+    from ddtrace import config, patch
+
+    patch(aws_durable_execution_sdk_python=True)
+
+
+Configuration
+~~~~~~~~~~~~~
+
+.. py:data:: ddtrace.config.aws_durable_execution_sdk_python["service"]
+
+   The service name reported by default for AWS Durable Execution SDK requests.
+
+   Alternatively, set this option with the ``DD_SERVICE`` or
+   ``DD_AWS_DURABLE_EXECUTION_SDK_PYTHON_SERVICE`` environment variable.
+
+   Default: ``"aws_durable_execution_sdk_python"``
+
+.. py:data:: ddtrace.config.aws_durable_execution_sdk_python["distributed_tracing_enabled"]
+
+   Whether to enable distributed tracing across chained Lambda invocations.
+   When enabled, trace context is injected into ``invoke()`` payloads and
+   extracted from the input event in ``@durable_execution`` handlers, linking
+   traces across service boundaries.
+
+   This option can also be set with the
+   ``DD_AWS_DURABLE_EXECUTION_SDK_PYTHON_DISTRIBUTED_TRACING`` environment variable.
+
+   Default: ``True``
+"""