Lambda: validate supported runtimes for managed instances

anisaoshafi · anisaoshafi · commit 8f1df6dcb583 · 2026-01-27T15:25:41.000+01:00
diff --git a/localstack-core/localstack/services/lambda_/provider.py b/localstack-core/localstack/services/lambda_/provider.py
@@ -233,6 +233,7 @@
     DEPRECATED_RUNTIMES_UPGRADES,
     RUNTIMES_AGGREGATED,
     SNAP_START_SUPPORTED_RUNTIMES,
+    VALID_MANAGED_INSTANCE_RUNTIMES,
     VALID_RUNTIMES,
 )
 from localstack.services.lambda_.urlrouter import FunctionUrlRouter
@@ -1076,6 +1077,7 @@ def create_function(
             if "CapacityProviderConfig" in request:
                 capacity_provider_config = request["CapacityProviderConfig"]
                 self._validate_capacity_provider_config(capacity_provider_config, context)
+                self._validate_managed_instances_runtime(runtime)
 
                 default_config = CapacityProviderConfig(
                     LambdaManagedInstancesCapacityProviderConfig=LambdaManagedInstancesCapacityProviderConfig(
@@ -1252,6 +1254,12 @@ def _validate_runtime(self, package_type, runtime):
                 Type="User",
             )
 
+    def _validate_managed_instances_runtime(self, runtime):
+        if runtime not in VALID_MANAGED_INSTANCE_RUNTIMES:
+            raise InvalidParameterValueException(
+                f"Runtime Enum {runtime} does not support specified feature: Lambda Managed Instances"
+            )
+
     def _check_for_recomended_migration_target(self, deprecated_runtime):
         # AWS offers recommended runtime for migration for "newly" deprecated runtimes
         # in order to preserve parity with error messages we need the code bellow
diff --git a/localstack-core/localstack/services/lambda_/runtimes.py b/localstack-core/localstack/services/lambda_/runtimes.py
@@ -176,3 +176,16 @@
 VALID_RUNTIMES: str = "[nodejs20.x, python3.14, provided.al2023, python3.12, python3.13, nodejs24.x, nodejs22.x, java25, python3.10, python3.11, java21, ruby3.3, ruby3.4, ruby3.2, python3.8, python3.9, java17, nodejs16.x, dotnet10, dotnet8, java11, dotnet6, nodejs18.x, provided.al2, java8.al2]"
 # An ordered list of all Lambda runtimes for layers considered valid by AWS. Matching snapshots in test_layer_exceptions
 VALID_LAYER_RUNTIMES: str = "[ruby3.5, ruby2.6, dotnetcore1.0, python3.7, nodejs8.10, nasa, ruby2.7, python2.7-greengrass, dotnetcore2.0, python3.8, java21, dotnet6, dotnetcore2.1, python3.9, java11, nodejs6.10, provided, dotnetcore3.1, dotnet8, java25, java17, nodejs, nodejs4.3, java8.al2, go1.x, dotnet10, nodejs20.x, go1.9, byol, nodejs10.x, provided.al2023, nodejs22.x, python3.10, java8, nodejs12.x, python3.11, nodejs24.x, nodejs8.x, python3.12, nodejs14.x, nodejs8.9, nodejs26.x, python3.13, python3.14, nodejs16.x, python3.15, provided.al2, nodejs4.3-edge, nodejs18.x, ruby3.2, python3.4, ruby3.3, ruby3.4, ruby2.5, python3.6, python2.7]"
+
+
+VALID_MANAGED_INSTANCE_RUNTIMES = [
+    Runtime.nodejs24_x,
+    Runtime.nodejs22_x,
+    Runtime.python3_14,
+    Runtime.python3_13,
+    Runtime.java25,
+    Runtime.java21,
+    Runtime.dotnet10,
+    Runtime.dotnet8,
+    Runtime.provided_al2023,
+]
diff --git a/localstack-core/localstack/testing/aws/lambda_utils.py b/localstack-core/localstack/testing/aws/lambda_utils.py
@@ -14,13 +14,14 @@
 from localstack.utils.files import load_file
 from localstack.utils.platform import Arch, get_arch
 from localstack.utils.strings import short_uid
-from localstack.utils.sync import ShortCircuitWaitException, retry
+from localstack.utils.sync import ShortCircuitWaitException, retry, wait_until
 from localstack.utils.testutil import get_lambda_log_events
 
 if TYPE_CHECKING:
     from mypy_boto3_lambda import LambdaClient
     from mypy_boto3_lambda.literals import ArchitectureType, PackageTypeType, RuntimeType
     from mypy_boto3_lambda.type_defs import (
+        CapacityProviderConfigTypeDef,
         DeadLetterConfigTypeDef,
         EnvironmentTypeDef,
         EphemeralStorageTypeDef,
@@ -200,6 +201,7 @@ def create_function(
         CodeSigningConfigArn: str | None = None,
         Architectures: Sequence["ArchitectureType"] | None = None,
         EphemeralStorage: Optional["EphemeralStorageTypeDef"] = None,
+        CapacityProviderConfig: Optional["CapacityProviderConfigTypeDef"] = None,
     ) -> "FunctionConfigurationResponseMetadataTypeDef": ...
 
     def create_function(self, **kwargs):
@@ -216,9 +218,22 @@ def _create_function():
         # localstack should normally not require the retries and will just continue here
         result = retry(_create_function, retries=3, sleep=4)
         self.function_names.append(result["FunctionArn"])
-        self.lambda_client.get_waiter("function_active_v2").wait(
-            FunctionName=kwargs.get("FunctionName")
-        )
+
+        def _is_not_pending():
+            try:
+                result = (
+                    self.lambda_client.get_function(FunctionName=kwargs.get("FunctionName"))[
+                        "Configuration"
+                    ]["State"]
+                    != "Pending"
+                )
+                LOG.debug("lambda state result: result=%s", result)
+                return result
+            except Exception as e:
+                LOG.error(e)
+                raise
+
+        wait_until(_is_not_pending)
 
         return result
 
