Apply ruff linting rules

Author: codingjoe

health_check/__init__.py

@@ -1,4 +1,4 @@
-"""Run a full check on the deployment,using a number of plugins to check internal and external services."""
+"""Monitor the health of your Django app and its connected services."""
 
 from . import _version  # noqa
 

health_check/cache/backends.py

@@ -21,9 +21,7 @@ class CacheBackend(BaseHealthCheckBackend):
     def __init__(self, backend="default"):
         super().__init__()
         self.backend = backend
-        self.cache_key = getattr(
-            settings, "HEALTHCHECK_CACHE_KEY", "djangohealthcheck_test"
-        )
+        self.cache_key = getattr(settings, "HEALTHCHECK_CACHE_KEY", "djangohealthcheck_test")
 
     def identifier(self):
         return f"Cache backend: {self.backend}"

health_check/contrib/celery/apps.py

@@ -24,7 +24,5 @@ def ready(self):
         for queue in current_app.amqp.queues:
             celery_class_name = "CeleryHealthCheck" + queue.title()
 
-            celery_class = type(
-                celery_class_name, (CeleryHealthCheck,), {"queue": queue}
-            )
+            celery_class = type(celery_class_name, (CeleryHealthCheck,), {"queue": queue})
             plugin_dir.register(celery_class)

health_check/contrib/celery/backends.py

@@ -15,36 +15,27 @@ def check_status(self):
         priority = getattr(settings, "HEALTHCHECK_CELERY_PRIORITY", None)
 
         try:
-            result = add.apply_async(
-                args=[4, 4], expires=queue_timeout, queue=self.queue, priority=priority
-            )
+            result = add.apply_async(args=[4, 4], expires=queue_timeout, queue=self.queue, priority=priority)
             result.get(timeout=result_timeout)
             if result.result != 8:
-                self.add_error(
-                    ServiceReturnedUnexpectedResult("Celery returned wrong result")
-                )
-        except IOError as e:
+                self.add_error(ServiceReturnedUnexpectedResult("Celery returned wrong result"))
+        except OSError as e:
             self.add_error(ServiceUnavailable("IOError"), e)
         except NotImplementedError as e:
             self.add_error(
-                ServiceUnavailable(
-                    "NotImplementedError: Make sure CELERY_RESULT_BACKEND is set"
-                ),
+                ServiceUnavailable("NotImplementedError: Make sure CELERY_RESULT_BACKEND is set"),
                 e,
             )
         except TaskRevokedError as e:
             self.add_error(
                 ServiceUnavailable(
-                    "TaskRevokedError: The task was revoked, likely because it spent "
-                    "too long in the queue"
+                    "TaskRevokedError: The task was revoked, likely because it spent too long in the queue"
                 ),
                 e,
             )
         except TimeoutError as e:
             self.add_error(
-                ServiceUnavailable(
-                    "TimeoutError: The task took too long to return a result"
-                ),
+                ServiceUnavailable("TimeoutError: The task took too long to return a result"),
                 e,
             )
         except BaseException as e:

health_check/contrib/celery_ping/backends.py

@@ -13,13 +13,11 @@ def check_status(self):
 
         try:
             ping_result = app.control.ping(timeout=timeout)
-        except IOError as e:
+        except OSError as e:
             self.add_error(ServiceUnavailable("IOError"), e)
         except NotImplementedError as exc:
             self.add_error(
-                ServiceUnavailable(
-                    "NotImplementedError: Make sure CELERY_RESULT_BACKEND is set"
-                ),
+                ServiceUnavailable("NotImplementedError: Make sure CELERY_RESULT_BACKEND is set"),
                 exc,
             )
         except BaseException as exc:
@@ -39,9 +37,7 @@ def _check_ping_result(self, ping_result):
             worker, response = list(result.items())[0]
             if response != self.CORRECT_PING_RESPONSE:
                 self.add_error(
-                    ServiceUnavailable(
-                        f"Celery worker {worker} response was incorrect"
-                    ),
+                    ServiceUnavailable(f"Celery worker {worker} response was incorrect"),
                 )
                 continue
             active_workers.append(worker)
@@ -50,9 +46,7 @@ def _check_ping_result(self, ping_result):
             self._check_active_queues(active_workers)
 
     def _check_active_queues(self, active_workers):
-        defined_queues = getattr(app.conf, "task_queues", None) or getattr(
-            app.conf, "CELERY_QUEUES", None
-        )
+        defined_queues = getattr(app.conf, "task_queues", None) or getattr(app.conf, "CELERY_QUEUES", None)
 
         if not defined_queues:
             return

health_check/contrib/db_heartbeat/backends.py

@@ -15,8 +15,6 @@ def check_status(self):
                 result = cursor.fetchone()
 
             if result != (1,):
-                raise ServiceUnavailable(
-                    "Health Check query did not return the expected result."
-                )
+                raise ServiceUnavailable("Health Check query did not return the expected result.")
         except Exception as e:
             raise ServiceUnavailable(f"Database health check failed: {e}")

health_check/contrib/psutil/backends.py

@@ -18,11 +18,7 @@ def check_status(self):
         try:
             du = psutil.disk_usage("/")
             if DISK_USAGE_MAX and du.percent >= DISK_USAGE_MAX:
-                raise ServiceWarning(
-                    "{host} {percent}% disk usage exceeds {disk_usage}%".format(
-                        host=host, percent=du.percent, disk_usage=DISK_USAGE_MAX
-                    )
-                )
+                raise ServiceWarning(f"{host} {du.percent}% disk usage exceeds {DISK_USAGE_MAX}%")
         except ValueError as e:
             self.add_error(ServiceReturnedUnexpectedResult("ValueError"), e)
 
@@ -33,12 +29,8 @@ def check_status(self):
             memory = psutil.virtual_memory()
             if MEMORY_MIN and memory.available < (MEMORY_MIN * 1024 * 1024):
                 locale.setlocale(locale.LC_ALL, "")
-                avail = "{:n}".format(int(memory.available / 1024 / 1024))
-                threshold = "{:n}".format(MEMORY_MIN)
-                raise ServiceWarning(
-                    "{host} {avail} MB available RAM below {threshold} MB".format(
-                        host=host, avail=avail, threshold=threshold
-                    )
-                )
+                avail = f"{int(memory.available / 1024 / 1024):n}"
+                threshold = f"{MEMORY_MIN:n}"
+                raise ServiceWarning(f"{host} {avail} MB available RAM below {threshold} MB")
         except ValueError as e:
             self.add_error(ServiceReturnedUnexpectedResult("ValueError"), e)

health_check/contrib/rabbitmq/backends.py

@@ -19,9 +19,7 @@ def check_status(self):
         """Check RabbitMQ service by opening and closing a broker channel."""
         logger.debug("Checking for a broker_url on django settings...")
 
-        broker_url_setting_key = (
-            f"{self.namespace}_BROKER_URL" if self.namespace else "BROKER_URL"
-        )
+        broker_url_setting_key = f"{self.namespace}_BROKER_URL" if self.namespace else "BROKER_URL"
         broker_url = getattr(settings, broker_url_setting_key, None)
 
         logger.debug("Got %s as the broker_url. Connecting to rabbit...", broker_url)
@@ -33,21 +31,17 @@ def check_status(self):
                 conn.connect()  # exceptions may be raised upon calling connect
         except ConnectionRefusedError as e:
             self.add_error(
-                ServiceUnavailable(
-                    "Unable to connect to RabbitMQ: Connection was refused."
-                ),
+                ServiceUnavailable("Unable to connect to RabbitMQ: Connection was refused."),
                 e,
             )
 
         except AccessRefused as e:
             self.add_error(
-                ServiceUnavailable(
-                    "Unable to connect to RabbitMQ: Authentication error."
-                ),
+                ServiceUnavailable("Unable to connect to RabbitMQ: Authentication error."),
                 e,
             )
 
-        except IOError as e:
+        except OSError as e:
             self.add_error(ServiceUnavailable("IOError"), e)
 
         except BaseException as e:

health_check/contrib/redis/backends.py

@@ -26,19 +26,13 @@ def check_status(self):
                 conn.ping()  # exceptions may be raised upon ping
         except ConnectionRefusedError as e:
             self.add_error(
-                ServiceUnavailable(
-                    "Unable to connect to Redis: Connection was refused."
-                ),
+                ServiceUnavailable("Unable to connect to Redis: Connection was refused."),
                 e,
             )
         except exceptions.TimeoutError as e:
-            self.add_error(
-                ServiceUnavailable("Unable to connect to Redis: Timeout."), e
-            )
+            self.add_error(ServiceUnavailable("Unable to connect to Redis: Timeout."), e)
         except exceptions.ConnectionError as e:
-            self.add_error(
-                ServiceUnavailable("Unable to connect to Redis: Connection Error"), e
-            )
+            self.add_error(ServiceUnavailable("Unable to connect to Redis: Connection Error"), e)
         except BaseException as e:
             self.add_error(ServiceUnavailable("Unknown error"), e)
         else:

health_check/db/migrations/0001_initial.py

@@ -1,5 +1,4 @@
 # Generated by Django 1.10.1 on 2016-09-26 18:46
-from __future__ import unicode_literals
 
 from django.db import migrations, models