localstack
diff --git a/‎localstack/services/stepfunctions/provider.py
Lines changed: 7 additions & 0 deletions b/‎localstack/services/stepfunctions/provider.py
Lines changed: 7 additions & 0 deletions
diff --git a/‎tests/integration/test_stepfunctions.py
Lines changed: 57 additions & 0 deletions b/‎tests/integration/test_stepfunctions.py
Lines changed: 57 additions & 0 deletions
@@ -5,6 +5,8 @@
     CreateStateMachineOutput,
     DeleteStateMachineInput,
     DeleteStateMachineOutput,
+    LoggingConfiguration,
+    LogLevel,
     StepfunctionsApi,
 )
 from localstack.aws.forwarder import HttpFallbackDispatcher, get_request_forwarder_http
@@ -42,6 +44,11 @@ def on_before_start(self):
     def create_state_machine(
         self, context: RequestContext, request: CreateStateMachineInput
     ) -> CreateStateMachineOutput:
+        # set default logging configuration
+        if not request.get("loggingConfiguration"):
+            request["loggingConfiguration"] = LoggingConfiguration(
+                level=LogLevel.OFF, includeExecutionData=False
+            )
         result = self.forward_request(context, request)
         event_publisher.fire_event(
             event_publisher.EVENT_STEPFUNCTIONS_CREATE_SM,
 
@@ -1,4 +1,5 @@
 import json
+import logging
 import os
 
 import pytest
@@ -163,6 +164,8 @@
     },
 }
 
+LOG = logging.getLogger(__name__)
+
 
 @pytest.fixture(scope="module")
 def setup_and_tear_down():
@@ -200,6 +203,24 @@ def setup_and_tear_down():
     testutil.delete_lambda_function(name=TEST_LAMBDA_NAME_5)
 
 
+@pytest.fixture
+def create_state_machine(stepfunctions_client):
+    machines_arns = []
+
+    def factory(**kwargs):
+        result = stepfunctions_client.create_state_machine(**kwargs)
+        machines_arns.append(result["stateMachineArn"])
+        return result
+
+    yield factory
+
+    for machine in machines_arns:
+        try:
+            stepfunctions_client.delete_state_machine(stateMachineArn=machine)
+        except Exception as e:
+            LOG.debug("Unable to delete SFN state machine: ", e)
+
+
 def _assert_machine_instances(expected_instances, sfn_client):
     def check():
         state_machines_after = sfn_client.list_state_machines()["stateMachines"]
@@ -516,6 +537,17 @@ def check_invocations():
     },
 }
 
+STS_ROLE_POLICY_DOC = {
+    "Version": "2012-10-17",
+    "Statement": [
+        {
+            "Effect": "Allow",
+            "Principal": {"Service": ["states.amazonaws.com"]},
+            "Action": "sts:AssumeRole",
+        }
+    ],
+}
+
 
 @pytest.mark.parametrize("region_name", ("us-east-1", "us-east-2", "eu-west-1", "eu-central-1"))
 @pytest.mark.parametrize("statemachine_definition", (TEST_STATE_MACHINE_3,))  # TODO: add sync2 test
@@ -570,6 +602,31 @@ def assert_success():
         client1.delete_state_machine(stateMachineArn=child_machine_arn)
 
 
+@pytest.mark.aws_validated
+def test_default_logging_configuration(iam_client, create_state_machine, stepfunctions_client):
+    role_name = f"role_name-{short_uid()}"
+    try:
+        role_arn = iam_client.create_role(
+            RoleName=role_name,
+            AssumeRolePolicyDocument=json.dumps(STS_ROLE_POLICY_DOC),
+        )["Role"]["Arn"]
+
+        definition = clone(TEST_STATE_MACHINE)
+        definition = json.dumps(definition)
+
+        sm_name = f"sts-logging-{short_uid()}"
+        result = create_state_machine(name=sm_name, definition=definition, roleArn=role_arn)
+
+        assert result["ResponseMetadata"]["HTTPStatusCode"] == 200
+        result = stepfunctions_client.describe_state_machine(
+            stateMachineArn=result["stateMachineArn"]
+        )
+        assert result["ResponseMetadata"]["HTTPStatusCode"] == 200
+        assert result["loggingConfiguration"] == {"level": "OFF", "includeExecutionData": False}
+    finally:
+        iam_client.delete_role(RoleName=role_name)
+
+
 def test_aws_sdk_task(stepfunctions_client, iam_client, sns_client):
     statemachine_definition = {
         "StartAt": "CreateTopicTask",