chore(ci): migrate E2E tests to CDK CLI and off Docker

.github/workflows/run-e2e-tests.yml

@@ -28,8 +28,8 @@ jobs:
     strategy:
       matrix:
         # Maintenance: disabled until we discover concurrency lock issue with multiple versions and tmp
-        # version: ["3.7", "3.8", "3.9"]
-        version: ["3.7"]
+        version: ["3.7", "3.8", "3.9"]
+        # version: ["3.7"]
     steps:
       - name: "Checkout"
         uses: actions/checkout@v3
@@ -41,6 +41,14 @@ jobs:
           python-version: ${{ matrix.version }}
           architecture: "x64"
           cache: "poetry"
+      - name: Setup Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: "16.12"
+      - name: Install CDK CLI
+        run: |
+          npm install
+          cdk --version
       - name: Install dependencies
         run: make dev
       - name: Configure AWS credentials

.gitignore

@@ -310,3 +310,7 @@ site/
 
 !.github/workflows/lib
 examples/**/sam/.aws-sam
+
+cdk.out
+# NOTE: different accounts will be used for E2E thus creating unnecessary git clutter
+cdk.context.json

aws_lambda_powertools/tracing/tracer.py

@@ -300,16 +300,6 @@ def handler(event, context):
         @functools.wraps(lambda_handler)
         def decorate(event, context, **kwargs):
             with self.provider.in_subsegment(name=f"## {lambda_handler_name}") as subsegment:
-                global is_cold_start
-                logger.debug("Annotating cold start")
-                subsegment.put_annotation(key="ColdStart", value=is_cold_start)
-
-                if is_cold_start:
-                    is_cold_start = False
-
-                if self.service:
-                    subsegment.put_annotation(key="Service", value=self.service)
-
                 try:
                     logger.debug("Calling lambda handler")
                     response = lambda_handler(event, context, **kwargs)
@@ -325,7 +315,18 @@ def decorate(event, context, **kwargs):
                     self._add_full_exception_as_metadata(
                         method_name=lambda_handler_name, error=err, subsegment=subsegment, capture_error=capture_error
                     )
+
                     raise
+                finally:
+                    global is_cold_start
+                    logger.debug("Annotating cold start")
+                    subsegment.put_annotation(key="ColdStart", value=is_cold_start)
+
+                    if is_cold_start:
+                        is_cold_start = False
+
+                    if self.service:
+                        subsegment.put_annotation(key="Service", value=self.service)
 
                 return response
 
@@ -672,7 +673,7 @@ def _add_response_as_metadata(
         if data is None or not capture_response or subsegment is None:
             return
 
-        subsegment.put_metadata(key=f"{method_name} response", value=data, namespace=self._config["service"])
+        subsegment.put_metadata(key=f"{method_name} response", value=data, namespace=self.service)
 
     def _add_full_exception_as_metadata(
         self,
@@ -697,7 +698,7 @@ def _add_full_exception_as_metadata(
         if not capture_error:
             return
 
-        subsegment.put_metadata(key=f"{method_name} error", value=error, namespace=self._config["service"])
+        subsegment.put_metadata(key=f"{method_name} error", value=error, namespace=self.service)
 
     @staticmethod
     def _disable_tracer_provider():

package.json

@@ -0,0 +1,7 @@
+{
+  "name": "aws-lambda-powertools-python-e2e",
+  "version": "1.0.0",
+  "devDependencies": {
+	"aws-cdk": "2.40.0"
+  }
+}

parallel_run_e2e.py

@@ -8,7 +8,6 @@ def main():
     workers = len(list(features)) - 1
 
     command = f"poetry run pytest -n {workers} --dist loadfile -o log_cli=true tests/e2e"
-    print(f"Running E2E tests with: {command}")
     subprocess.run(command.split(), shell=False)