[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

anta/device.py

@@ -15,13 +15,13 @@
 import httpcore
 from aiocache import Cache
 from aiocache.plugins import HitMissRatioPlugin
-from asynceapi import Device, EapiCommandError
 from asyncssh import SSHClientConnection, SSHClientConnectionOptions
 from httpx import ConnectError, HTTPError, Limits, TimeoutException
 
 from anta import __DEBUG__
 from anta.logger import anta_log_exception, exc_to_str
 from anta.models import AntaCommand
+from asynceapi import Device, EapiCommandError
 
 if TYPE_CHECKING:
     from collections.abc import Iterator
@@ -332,7 +332,7 @@ async def _handle_eapi_command_error(self, exception: EapiCommandError, anta_com
             logger.error("Command '%s' is not supported on %s (%s).", anta_command.command, self.name, self.hw_model)
 
         # Collect the commands that were not executed
-        await self._collect(anta_commands=anta_commands[err_at + 1:], req_format=req_format, req_id=req_id)
+        await self._collect(anta_commands=anta_commands[err_at + 1 :], req_format=req_format, req_id=req_id)
 
     def _handle_timeout_exception(self, exception: TimeoutException, anta_commands: list[AntaCommand]) -> None:
         """Handle TimeoutException exceptions."""
@@ -357,7 +357,9 @@ def _handle_connect_os_error(self, exception: ConnectError | OSError, anta_comma
         for anta_command in anta_commands:
             anta_command.errors = [exc_to_str(exception)]
 
-        if (isinstance(exc := exception.__cause__, httpcore.ConnectError) and isinstance(os_error := exc.__context__, OSError)) or isinstance(os_error := exception, OSError):
+        if (isinstance(exc := exception.__cause__, httpcore.ConnectError) and isinstance(os_error := exc.__context__, OSError)) or isinstance(
+            os_error := exception, OSError
+        ):
             if isinstance(os_error.__cause__, OSError):
                 os_error = os_error.__cause__
             logger.error("A local OS error occurred while connecting to %s: %s.", self.name, os_error)
@@ -385,8 +387,7 @@ async def _collect(self, anta_commands: list[AntaCommand], *, req_format: Litera
             collection_id: An identifier used to build the eAPI request ID.
         """
         commands = [
-            {"cmd": anta_command.command, "revision": anta_command.revision}
-            if anta_command.revision else {"cmd": anta_command.command}
+            {"cmd": anta_command.command, "revision": anta_command.revision} if anta_command.revision else {"cmd": anta_command.command}
             for anta_command in anta_commands
         ]
 

anta/models.py

@@ -127,6 +127,7 @@ def render(self, **params: str | int | bool) -> AntaCommand:
             use_cache=self.use_cache,
         )
 
+
 class CommandWeight(Enum):
     """Enum to define the weight of a command.
 
@@ -138,6 +139,7 @@ class CommandWeight(Enum):
     MEDIUM = "medium"
     HEAVY = "heavy"
 
+
 class AntaCommand(BaseModel):
     """Class to define a command.
 
@@ -660,6 +662,7 @@ def test(self) -> None:
 
         """
 
+
 class AntaTestManager:
     """TODO: Add docstring.
 

anta/runner.py

@@ -155,6 +155,7 @@ def prepare_tests(
 
     return device_to_tests
 
+
 async def run_device_tests(device: AntaDevice, test_definitions: set[AntaTestDefinition], batch_size: int) -> list[TestResult]:
     """Run tests for a specific device using the AntaTestManager."""
     manager = AntaTestManager(device=device, batch_size=batch_size)