feat(python): add stack-advanced gate scenarios for 3.14/3.15

Add paired asyncio (task name labels), native_cpu (C-extension frames),
and deep_stack (deep unwinding) scenarios. Gate grows from 14 to 20.

Author: vlad-scherbich

README.md

@@ -55,7 +55,7 @@ Both use [dd-octo-sts](https://github.com/DataDog/dd-octo-sts-action) (`dd-trace
 **Inputs:**
 
 - `dd_trace_py_commit_sha` — commit to test (required)
-- `test_scenarios` — regexp passed to `TEST_SCENARIOS` (dd-trace-py passes the [10-scenario 3.14/3.15 migration gate](scenarios/python_downstream_gate/README.md); the downstream workflow default alone is `python.*`)
+- `test_scenarios` — regexp passed to `TEST_SCENARIOS` (dd-trace-py passes the [16-scenario 3.14/3.15 migration gate](scenarios/python_downstream_gate/README.md); the downstream workflow default alone is `python.*`)
 
 ## Creating new tests 
 

scenarios/python_asyncio_3.14/Dockerfile

@@ -0,0 +1,15 @@
+ARG BASE_IMAGE="prof-python-3.14"
+FROM $BASE_IMAGE
+
+COPY ./scenarios/python_asyncio_3.14/requirements.txt /app/requirements.txt
+RUN pip install -r /app/requirements.txt
+
+COPY ./scenarios/python_asyncio_3.14/main.py /app/main.py
+WORKDIR /app
+
+ENV EXECUTION_TIME_SEC=5
+ENV ECHION_USE_FAST_COPY_MEMORY=1
+ENV _DD_PROFILING_STACK_ADAPTIVE_SAMPLING_ENABLED=0
+ENV DD_PROFILING_ENABLED=true
+
+CMD ddtrace-run python main.py

scenarios/python_asyncio_3.14/README.md

@@ -0,0 +1,6 @@
+## Asyncio task-name labels (3.14 baseline)
+
+Validates **wall-time** stack samples carry asyncio `task name` labels (named and
+unnamed tasks). Migration pair baseline; see `python_asyncio_3.15`.
+
+Reuses `scenarios/python_asyncio_3.11` workload.

scenarios/python_asyncio_3.14/expected_profile.json

@@ -0,0 +1,52 @@
+{
+  "test_name": "python_asyncio_3.14",
+  "stacks": [
+    {
+      "profile-type": "wall-time",
+      "stack-content": [
+        {
+          "regular_expression": ".*my_coroutine.*",
+          "percent": 50,
+          "error_margin": 100,
+          "labels": [
+            {
+              "key": "thread name",
+              "values": [
+                "MainThread"
+              ]
+            },
+            {
+              "key": "task name",
+              "values": [
+                "short_task"
+              ]
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "profile-type": "wall-time",
+      "stack-content": [
+        {
+          "regular_expression": ".*my_coroutine.*",
+          "percent": 50,
+          "error_margin": 100,
+          "labels": [
+            {
+              "key": "thread name",
+              "values": [
+                "MainThread"
+              ]
+            },
+            {
+              "key": "task name",
+              "values_regex": "Task-[0-9]+"
+            }
+          ]
+        }
+      ]
+    }
+  ],
+  "scale_by_duration": false
+}

scenarios/python_asyncio_3.14/main.py

@@ -0,0 +1,27 @@
+import asyncio
+import os
+
+
+async def my_coroutine(n: float) -> None:
+    await asyncio.sleep(n)
+
+
+async def main() -> None:
+    # Simple application that creates two Tasks with different durations:
+    # - "unnamed Task" runs my_coroutine() for 2 second
+    # - short_task runs my_coroutine() for 1 second
+    # The profiler should capture both Tasks with their respective durations.
+
+    # Give the Profiler some time to start up
+    await asyncio.sleep(0.5)
+
+    execution_time_sec = float(os.environ.get("EXECUTION_TIME_SEC", "5"))
+
+    short_task = asyncio.create_task(my_coroutine(execution_time_sec / 2.0), name="short_task")
+
+    # asyncio.gather will automatically wrap my_coroutine into a Task
+    await asyncio.gather(short_task, my_coroutine(execution_time_sec))
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

scenarios/python_asyncio_3.14/requirements.txt

@@ -0,0 +1 @@
+ddtrace

scenarios/python_asyncio_3.15/Dockerfile

@@ -0,0 +1,12 @@
+ARG BASE_IMAGE="prof-python-3.15"
+FROM $BASE_IMAGE
+
+COPY ./scenarios/python_asyncio_3.15/main.py /app/main.py
+WORKDIR /app
+
+ENV EXECUTION_TIME_SEC=5
+ENV ECHION_USE_FAST_COPY_MEMORY=1
+ENV _DD_PROFILING_STACK_ADAPTIVE_SAMPLING_ENABLED=0
+ENV DD_PROFILING_ENABLED=true
+
+CMD ddtrace-run python main.py

scenarios/python_asyncio_3.15/README.md

@@ -0,0 +1,4 @@
+## Asyncio task-name labels (3.15 candidate)
+
+Wheel-only 3.15 candidate half of the asyncio task-name gate pair. See
+`python_asyncio_3.14`.

scenarios/python_asyncio_3.15/expected_profile.json

@@ -0,0 +1,52 @@
+{
+  "test_name": "python_asyncio_3.15",
+  "stacks": [
+    {
+      "profile-type": "wall-time",
+      "stack-content": [
+        {
+          "regular_expression": ".*my_coroutine.*",
+          "percent": 50,
+          "error_margin": 100,
+          "labels": [
+            {
+              "key": "thread name",
+              "values": [
+                "MainThread"
+              ]
+            },
+            {
+              "key": "task name",
+              "values": [
+                "short_task"
+              ]
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "profile-type": "wall-time",
+      "stack-content": [
+        {
+          "regular_expression": ".*my_coroutine.*",
+          "percent": 50,
+          "error_margin": 100,
+          "labels": [
+            {
+              "key": "thread name",
+              "values": [
+                "MainThread"
+              ]
+            },
+            {
+              "key": "task name",
+              "values_regex": "Task-[0-9]+"
+            }
+          ]
+        }
+      ]
+    }
+  ],
+  "scale_by_duration": false
+}

scenarios/python_asyncio_3.15/main.py

@@ -0,0 +1,27 @@
+import asyncio
+import os
+
+
+async def my_coroutine(n: float) -> None:
+    await asyncio.sleep(n)
+
+
+async def main() -> None:
+    # Simple application that creates two Tasks with different durations:
+    # - "unnamed Task" runs my_coroutine() for 2 second
+    # - short_task runs my_coroutine() for 1 second
+    # The profiler should capture both Tasks with their respective durations.
+
+    # Give the Profiler some time to start up
+    await asyncio.sleep(0.5)
+
+    execution_time_sec = float(os.environ.get("EXECUTION_TIME_SEC", "5"))
+
+    short_task = asyncio.create_task(my_coroutine(execution_time_sec / 2.0), name="short_task")
+
+    # asyncio.gather will automatically wrap my_coroutine into a Task
+    await asyncio.gather(short_task, my_coroutine(execution_time_sec))
+
+
+if __name__ == "__main__":
+    asyncio.run(main())