feat: add support for Durable Functions

Author: valerena

.cfnlintrc.yaml

@@ -148,6 +148,7 @@ ignore_templates:
   - tests/translator/output/**/function_with_tenancy_and_api_event.json # cfnlint is not updated to recognize the TenancyConfig property
   - tests/translator/output/**/function_with_tenancy_and_httpapi_event.json # cfnlint is not updated to recognize the TenancyConfig property
   - tests/translator/output/**/function_with_tenancy_config_global.json # cfnlint is not updated to recognize the TenancyConfig property
+  - tests/translator/output/**/*durable_config*.json # TODO: Remove this once Durable Function is launched in CFN
 
 ignore_checks:
   - E2531 # Deprecated runtime; not relevant for transform tests

samtranslator/internal/schema_source/aws_serverless_function.py

@@ -662,6 +662,7 @@ class Properties(BaseModel):
     RecursiveLoop: Optional[PassThroughProp]  # TODO: add documentation
     SourceKMSKeyArn: Optional[PassThroughProp]  # TODO: add documentation
     TenancyConfig: Optional[PassThroughProp]  # TODO: add documentation
+    DurableConfig: Optional[PassThroughProp]  # TODO: add documentation
 
 
 class Globals(BaseModel):
@@ -723,6 +724,7 @@ class Globals(BaseModel):
     RecursiveLoop: Optional[PassThroughProp]  # TODO: add documentation
     SourceKMSKeyArn: Optional[PassThroughProp]  # TODO: add documentation
     TenancyConfig: Optional[PassThroughProp]  # TODO: add documentation
+    DurableConfig: Optional[PassThroughProp]  # TODO: add documentation
 
 
 class Resource(ResourceAttributes):

samtranslator/model/lambda_.py

@@ -37,6 +37,7 @@ class LambdaFunction(Resource):
         "LoggingConfig": GeneratedProperty(),
         "RecursiveLoop": GeneratedProperty(),
         "TenancyConfig": GeneratedProperty(),
+        "DurableConfig": GeneratedProperty(),
     }
 
     Code: Dict[str, Any]
@@ -66,6 +67,7 @@ class LambdaFunction(Resource):
     LoggingConfig: Optional[Dict[str, Any]]
     RecursiveLoop: Optional[str]
     TenancyConfig: Optional[Dict[str, Any]]
+    DurableConfig: Optional[Dict[str, Any]]
 
     runtime_attrs = {"name": lambda self: ref(self.logical_id), "arn": lambda self: fnGetAtt(self.logical_id, "Arn")}
 

samtranslator/model/sam_resources.py

@@ -185,6 +185,7 @@ class SamFunction(SamResourceMacro):
         "RecursiveLoop": PassThroughProperty(False),
         "SourceKMSKeyArn": PassThroughProperty(False),
         "TenancyConfig": PassThroughProperty(False),
+        "DurableConfig": PropertyType(False, IS_DICT),
     }
 
     FunctionName: Optional[Intrinsicable[str]]
@@ -230,6 +231,7 @@ class SamFunction(SamResourceMacro):
     RecursiveLoop: Optional[str]
     SourceKMSKeyArn: Optional[str]
     TenancyConfig: Optional[Dict[str, Any]]
+    DurableConfig: Optional[Dict[str, Any]]
 
     event_resolver = ResourceTypeResolver(
         samtranslator.model.eventsources,
@@ -655,6 +657,7 @@ def _construct_lambda_function(self, intrinsics_resolver: IntrinsicsResolver) ->
         lambda_function.LoggingConfig = self.LoggingConfig
         lambda_function.TenancyConfig = self.TenancyConfig
         lambda_function.RecursiveLoop = self.RecursiveLoop
+        lambda_function.DurableConfig = self.DurableConfig
         self._validate_package_type(lambda_function)
         return lambda_function
 

samtranslator/plugins/globals/globals.py

@@ -57,6 +57,7 @@ class Globals:
             "RecursiveLoop",
             "SourceKMSKeyArn",
             "TenancyConfig",
+            "DurableConfig",
         ],
         # Everything except
         #   DefinitionBody: because its hard to reason about merge of Swagger dictionaries
@@ -107,6 +108,7 @@ class Globals:
             "RecursiveLoop",
             "SourceKMSKeyArn",
             "TenancyConfig",
+            "DurableConfig",
         ],
     }
 

samtranslator/schema/schema.json

@@ -142798,6 +142798,11 @@
               "title": "Description",
               "type": "string"
             },
+            "DurableConfig": {
+              "$ref": "#/definitions/AWS::Lambda::Function.DurableConfig",
+              "markdownDescription": "Configuration for durable function execution.",
+              "title": "DurableConfig"
+            },
             "Environment": {
               "$ref": "#/definitions/AWS::Lambda::Function.Environment",
               "markdownDescription": "Environment variables that are accessible from function code during execution.",
@@ -142977,6 +142982,22 @@
       },
       "type": "object"
     },
+    "AWS::Lambda::Function.DurableConfig": {
+      "additionalProperties": false,
+      "properties": {
+        "ExecutionTimeout": {
+          "markdownDescription": "The maximum execution timeout in seconds for durable function executions.",
+          "title": "ExecutionTimeout",
+          "type": "number"
+        },
+        "RetentionPeriodInDays": {
+          "markdownDescription": "The retention period in days for durable function execution history.",
+          "title": "RetentionPeriodInDays",
+          "type": "number"
+        }
+      },
+      "type": "object"
+    },
     "AWS::Lambda::Function.Environment": {
       "additionalProperties": false,
       "properties": {
@@ -278453,6 +278474,9 @@
           "markdownDescription": "A description of the function\\.  \n*Type*: String  \n*Required*: No  \n*AWS CloudFormation compatibility*: This property is passed directly to the [`Description`](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-function.html#cfn-lambda-function-description) property of an `AWS::Lambda::Function` resource\\.",
           "title": "Description"
         },
+        "DurableConfig": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Environment": {
           "$ref": "#/definitions/AWS::Lambda::Function.Environment",
           "markdownDescription": "The configuration for the runtime environment\\.  \n*Type*: [Environment](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html)  \n*Required*: No  \n*AWS CloudFormation compatibility*: This property is passed directly to the [`Environment`](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html) property of an `AWS::Lambda::Function` resource\\.",
@@ -278704,6 +278728,9 @@
           "title": "Description",
           "type": "string"
         },
+        "DurableConfig": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Environment": {
           "$ref": "#/definitions/AWS::Lambda::Function.Environment",
           "markdownDescription": "The configuration for the runtime environment\\.  \n*Type*: [Environment](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html)  \n*Required*: No  \n*AWS CloudFormation compatibility*: This property is passed directly to the [`Environment`](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html) property of an `AWS::Lambda::Function` resource\\.",

schema_source/cloudformation.schema.json

@@ -142749,6 +142749,11 @@
               "title": "Description",
               "type": "string"
             },
+            "DurableConfig": {
+              "$ref": "#/definitions/AWS::Lambda::Function.DurableConfig",
+              "markdownDescription": "Configuration for durable function execution.",
+              "title": "DurableConfig"
+            },
             "Environment": {
               "$ref": "#/definitions/AWS::Lambda::Function.Environment",
               "markdownDescription": "Environment variables that are accessible from function code during execution.",
@@ -143119,6 +143124,22 @@
       },
       "type": "object"
     },
+    "AWS::Lambda::Function.DurableConfig": {
+      "additionalProperties": false,
+      "properties": {
+        "ExecutionTimeout": {
+          "markdownDescription": "The maximum execution timeout in seconds for durable function executions.",
+          "title": "ExecutionTimeout",
+          "type": "number"
+        },
+        "RetentionPeriodInDays": {
+          "markdownDescription": "The retention period in days for durable function execution history.",
+          "title": "RetentionPeriodInDays",
+          "type": "number"
+        }
+      },
+      "type": "object"
+    },
     "AWS::Lambda::LayerVersion": {
       "additionalProperties": false,
       "properties": {

schema_source/sam.schema.json

@@ -5476,6 +5476,9 @@
           "markdownDescription": "A description of the function\\.  \n*Type*: String  \n*Required*: No  \n*AWS CloudFormation compatibility*: This property is passed directly to the [`Description`](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-function.html#cfn-lambda-function-description) property of an `AWS::Lambda::Function` resource\\.",
           "title": "Description"
         },
+        "DurableConfig": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Environment": {
           "__samPassThrough": {
             "markdownDescriptionOverride": "The configuration for the runtime environment\\.  \n*Type*: [Environment](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html)  \n*Required*: No  \n*AWS CloudFormation compatibility*: This property is passed directly to the [`Environment`](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html) property of an `AWS::Lambda::Function` resource\\.",
@@ -5853,6 +5856,9 @@
           ],
           "title": "Description"
         },
+        "DurableConfig": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Environment": {
           "__samPassThrough": {
             "markdownDescriptionOverride": "The configuration for the runtime environment\\.  \n*Type*: [Environment](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html)  \n*Required*: No  \n*AWS CloudFormation compatibility*: This property is passed directly to the [`Environment`](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-function-environment.html) property of an `AWS::Lambda::Function` resource\\.",

tests/translator/input/function_with_durable_config.yaml

@@ -0,0 +1,10 @@
+Resources:
+  FunctionWithDurableConfig:
+    Type: AWS::Serverless::Function
+    Properties:
+      CodeUri: s3://sam-demo-bucket/hello.zip
+      Handler: hello.handler
+      Runtime: python3.9
+      DurableConfig:
+        ExecutionTimeout: 3600
+        RetentionPeriodInDays: 45

tests/translator/input/function_with_durable_config_globals.yaml

@@ -0,0 +1,27 @@
+Globals:
+  Function:
+    Runtime: python3.11
+    Handler: index.handler
+    DurableConfig:
+      ExecutionTimeout: 3600
+      RetentionPeriodInDays: 30
+
+Resources:
+  DurableFunctionWithGlobals:
+    Type: AWS::Serverless::Function
+    Properties:
+      CodeUri: s3://my-bucket/my-function.zip
+
+  DurableFunctionWithOverride:
+    Type: AWS::Serverless::Function
+    Properties:
+      CodeUri: s3://my-bucket/my-function.zip
+      DurableConfig:
+        ExecutionTimeout: 7200
+        RetentionPeriodInDays: 7
+
+  RegularFunction:
+    Type: AWS::Serverless::Function
+    Properties:
+      CodeUri: s3://my-bucket/my-function.zip
+      # This function should inherit the global DurableConfig