Linting

tests/test_ecs/test_ecs_cloudformation.py

@@ -3,6 +3,7 @@ import json
 from copy import deepcopy
 from moto import mock_cloudformation, mock_ecs
 
+
 @mock_ecs
 @mock_cloudformation
 def test_update_task_definition_family_through_cloudformation_should_trigger_a_replacement():
@@ -250,4 +251,4 @@ def test_create_task_definition_through_cloudformation():
     task_definition_details = cfn_conn.describe_stack_resource(
         StackName=stack_name, LogicalResourceId="testTaskDefinition"
     )["StackResourceDetail"]
-    task_definition_details["PhysicalResourceId"].should.equal(task_definition_arn)
+    task_definition_details["PhysicalResourceId"].should.equal(task_definition_arn)

tests/test_elbv2/test_elbv2_cloudformation.py

@@ -345,4 +345,4 @@ def test_fixed_response_action_listener_rule_cloudformation():
                 },
             }
         ]
-    )
+    )

tests/test_logs/test_integration.py

@@ -380,4 +380,4 @@ def _wait_for_log_msg(client, log_group_name, expected_msg_part):
             if expected_msg_part in message:
                 return True, message
         time.sleep(1)
-    return False, received_messages
+    return False, received_messages

tests/test_sqs/test_sqs.py

@@ -2048,7 +2048,12 @@ def test_invoke_function_from_sqs_exception():
     assert response["EventSourceArn"] == queue.attributes["QueueArn"]
     assert response["State"] == "Enabled"
 
-    entries = [{"Id": "1", "MessageBody": json.dumps({"uuid": str(uuid.uuid4()), "test": "test"})}]
+    entries = [
+        {
+            "Id": "1",
+            "MessageBody": json.dumps({"uuid": str(uuid.uuid4()), "test": "test"}),
+        }
+    ]
 
     queue.send_messages(Entries=entries)