flake8 fixes

martinzink · Feb 6, 2025 · 8d961f8 · 8d961f8
1 parent 8b7c445
commit 8d961f8
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 8 deletions.
diff --git a/docker/test/integration/cluster/ContainerStore.py b/docker/test/integration/cluster/ContainerStore.py
@@ -157,11 +157,11 @@ def acquire_container(self, context, container_name: str, engine='minifi-cpp', c
         elif engine == 'kinesis-server':
             return self.containers.setdefault(container_name,
                                               KinesisServerContainer(feature_context=feature_context,
-                                                                    name=container_name,
-                                                                    vols=self.vols,
-                                                                    network=self.network,
-                                                                    image_store=self.image_store,
-                                                                    command=command))
+                                                                     name=container_name,
+                                                                     vols=self.vols,
+                                                                     network=self.network,
+                                                                     image_store=self.image_store,
+                                                                     command=command))
         elif engine == 'azure-storage-server':
             return self.containers.setdefault(container_name,
                                               AzureStorageServerContainer(feature_context=feature_context,

diff --git a/docker/test/integration/cluster/DockerTestCluster.py b/docker/test/integration/cluster/DockerTestCluster.py
@@ -194,7 +194,6 @@ def check_kinesis_server_record_data(self, container_name, record_data):
         container_name = self.container_store.get_container_name_with_postfix(container_name)
         return self.aws_checker.check_kinesis_server_record_data(container_name, record_data)
 
-
     def check_s3_server_object_data(self, container_name, test_data):
         container_name = self.container_store.get_container_name_with_postfix(container_name)
         return self.aws_checker.check_s3_server_object_data(container_name, test_data)

diff --git a/docker/test/integration/cluster/checkers/AwsChecker.py b/docker/test/integration/cluster/checkers/AwsChecker.py
@@ -25,7 +25,6 @@ def check_kinesis_server_record_data(self, container_name, record_data):
         (code, output) = self.container_communicator.execute_command(container_name, ["node", "/app/consumer/consumer.js", record_data])
         return code == 0
 
-
     @retry_check()
     def check_s3_server_object_data(self, container_name, test_data):
         (code, output) = self.container_communicator.execute_command(container_name, ["find", "/s3mockroot/test_bucket", "-mindepth", "1", "-maxdepth", "1", "-type", "d"])

diff --git a/docker/test/integration/features/steps/steps.py b/docker/test/integration/features/steps/steps.py
@@ -464,12 +464,12 @@ def step_impl(context):
 def step_impl(context):
     context.test.acquire_container(context=context, name="s3-server", engine="s3-server")
 
+
 @given("a kinesis server is set up in correspondence with the PutKinesisStream")
 def step_impl(context):
     context.test.acquire_container(context=context, name="kinesis-server", engine="kinesis-server")
 
 
-
 # azure storage setup
 @given("an Azure storage server is set up")
 def step_impl(context):
@@ -906,6 +906,7 @@ def step_impl(context, duration):
 def step_impl(context, url):
     context.test.check_http_proxy_access('http-proxy', url)
 
+
 @then("there is a record on the kinesis server with \"{record_data}\"")
 def step_impl(context, record_data):
     context.test.check_kinesis_server_record_data("kinesis-server", record_data)