chore: more fixes

Author: darklight3it

examples/basic-lambda-concurrent/src/main.rs

@@ -27,6 +27,9 @@ async fn main() -> Result<(), Error> {
     // required to enable CloudWatch error logging by the runtime
     tracing::init_default_subscriber();
 
+    let max_concurrency = std::env::var("AWS_LAMBDA_MAX_CONCURRENCY").unwrap_or_else(|_| "not set".to_string());
+    tracing::info!(AWS_LAMBDA_MAX_CONCURRENCY = %max_concurrency, "starting concurrent handler");
+
     let func = service_fn(my_handler);
     if let Err(err) = lambda_runtime::run_concurrent(func).await {
         tracing::error!(error = %err, "run error");

…st/dockerized/scenarios/lmi_scenarios.py …erized/scenarios/concurrent_scenarios.pytest/dockerized/scenarios/lmi_scenarios.py renamed to test/dockerized/scenarios/concurrent_scenarios.py test/dockerized/scenarios/lmi_scenarios.py renamed to test/dockerized/scenarios/concurrent_scenarios.py

@@ -10,7 +10,7 @@
 
 HANDLER = "basic-lambda-concurrent"
 IMAGE = os.environ.get("TEST_IMAGE", "local/test-base")
-DEFAULT_CONCURRENCY = 1
+DEFAULT_CONCURRENCY = 2
 
 
 def _make_env(concurrency: int = DEFAULT_CONCURRENCY) -> dict:
@@ -21,7 +21,7 @@ def _make_env(concurrency: int = DEFAULT_CONCURRENCY) -> dict:
     }
 
 
-def get_lmi_scenarios():
+def get_concurrent_scenarios():
     scenarios = []
 
     # Happy path: DEFAULT_CONCURRENCY unique commands all succeed concurrently
@@ -33,18 +33,18 @@ def get_lmi_scenarios():
         for i in range(DEFAULT_CONCURRENCY)
     ]
     scenarios.append(ConcurrentTest(
-        name="lmi_concurrent_happy_path",
+        name="concurrent_happy_path",
         handler=HANDLER,
         environment_variables=_make_env(),
         request_batches=[batch],
         image=IMAGE,
     ))
 
-    # Error isolation: 9 invalid payloads + 1 valid — the valid one must still succeed
+    # Error isolation: N-1 invalid payloads + 1 valid — the valid one must still succeed
     mixed_batch = [
         Request(
             payload={"not_a_command": "oops"},
-            assertions=[{"transform": ".errorType", "error": "Runtime.UnmarshalError"}],
+            assertions=[{"errorType": "&lambda_runtime::deserializer::DeserializeError"}],
         )
         for _ in range(DEFAULT_CONCURRENCY - 1)
     ] + [
@@ -54,7 +54,7 @@ def get_lmi_scenarios():
         )
     ]
     scenarios.append(ConcurrentTest(
-        name="lmi_error_isolation",
+        name="concurrent_error_isolation",
         handler=HANDLER,
         environment_variables=_make_env(),
         request_batches=[mixed_batch],