From 7eb1d9f737ed42177f212bcd1e7d4d6329371365 Mon Sep 17 00:00:00 2001 From: Lars Holmberg Date: Fri, 13 Sep 2024 10:56:52 +0200 Subject: [PATCH] black --- locust_plugins/users/ftp.py | 44 +++++++++++++++++++++++-------------- test/test_missing_extras.py | 2 +- 2 files changed, 29 insertions(+), 17 deletions(-) diff --git a/locust_plugins/users/ftp.py b/locust_plugins/users/ftp.py index 5a9e542..b8ae1a7 100644 --- a/locust_plugins/users/ftp.py +++ b/locust_plugins/users/ftp.py @@ -25,7 +25,7 @@ def __init__(self, environment): self.user = None self.host = None - def connect(self, user='anonymous', password='anonymous@', port=21, timeout=5, tls=False, passive_mode=False): + def connect(self, user="anonymous", password="anonymous@", port=21, timeout=5, tls=False, passive_mode=False): self.user = user if tls: self.connection = ftplib.FTP_TLS() @@ -46,7 +46,7 @@ def download_file(self, remote_file_name, local_dir_path): exception = None response = "" try: - with open(local_file_path, 'wb') as local_file: + with open(local_file_path, "wb") as local_file: response = self.connection.retrbinary("RETR " + remote_file_name, local_file.write) response_time = (time.perf_counter() - start_perf_counter) * 1000 except ftplib.all_errors as e: @@ -54,14 +54,20 @@ def download_file(self, remote_file_name, local_dir_path): response_time = (time.perf_counter() - start_perf_counter) * 1000 if exception: - self.environment.events.request.fire(request_type="FTP download", name=remote_file_name, - exception=exception, - response_time=response_time, - response_length=len(str(exception))) + self.environment.events.request.fire( + request_type="FTP download", + name=remote_file_name, + exception=exception, + response_time=response_time, + response_length=len(str(exception)), + ) else: - self.environment.events.request.fire(request_type="FTP download", name=remote_file_name, - response_time=response_time, - response_length=len(response)) + self.environment.events.request.fire( + request_type="FTP download", + name=remote_file_name, + response_time=response_time, + response_length=len(response), + ) def upload_file(self, local_file_path): local_file_path = os.path.normpath(local_file_path) @@ -77,14 +83,20 @@ def upload_file(self, local_file_path): response_time = (time.perf_counter() - start_perf_counter) * 1000 if exception: - self.environment.events.request.fire(request_type="FTP upload", name=local_file_path, - exception=exception, - response_time=response_time, - response_length=len(str(exception))) + self.environment.events.request.fire( + request_type="FTP upload", + name=local_file_path, + exception=exception, + response_time=response_time, + response_length=len(str(exception)), + ) else: - self.environment.events.request.fire(request_type="FTP upload", name=local_file_path, - response_time=response_time, - response_length=len(response)) + self.environment.events.request.fire( + request_type="FTP upload", + name=local_file_path, + response_time=response_time, + response_length=len(response), + ) def disconnect(self): self.connection.close() diff --git a/test/test_missing_extras.py b/test/test_missing_extras.py index b59833f..75a0701 100644 --- a/test/test_missing_extras.py +++ b/test/test_missing_extras.py @@ -16,4 +16,4 @@ def test_error_messages(self): with self.assertLogs("root") as cm: with self.assertRaises(SystemExit): importlib.import_module(module) - self.assertIn("you need to install it using \"pip install", cm.output[0]) + self.assertIn('you need to install it using "pip install', cm.output[0])