Address ruff COM

pyproject.toml

@@ -277,7 +277,6 @@ ignore = [
   'C409', # [*] Unnecessary `list` literal passed to `tuple()` (rewrite as a `tuple` literal)
   'C414', # [*] Unnecessary `list` call within `sorted()`
   'C901', # `_params_row_for_entry` is too complex (11 > 10)
-  'COM812', # [*] Trailing comma missing
   'D100', # Missing docstring in public module
   'D101', # Missing docstring in public class
   'D102', # Missing docstring in public method

src/ansible_navigator/action_base.py

@@ -34,7 +34,10 @@ class ActionBase:
     """Base class for actions."""
 
     def __init__(
-        self, args: ApplicationConfiguration, name: str, logger_name: str = __name__
+        self,
+        args: ApplicationConfiguration,
+        name: str,
+        logger_name: str = __name__,
     ) -> None:
         """Initialize the App class.
 

src/ansible_navigator/actions/collections.py

@@ -463,13 +463,15 @@ def _run_runner(self) -> None:
             mount_doc_cache = True
             # Determine if the doc_cache is relative to the cache directory
             if path_is_relative_to(
-                child=Path(self._args.collection_doc_cache_path), parent=(cache_path)
+                child=Path(self._args.collection_doc_cache_path),
+                parent=(cache_path),
             ):
                 mount_doc_cache = False
 
             # The playbook directory will be mounted as host_cwd, so don't duplicate
             if path_is_relative_to(
-                child=Path(self._args.collection_doc_cache_path), parent=(Path(playbook_dir))
+                child=Path(self._args.collection_doc_cache_path),
+                parent=(Path(playbook_dir)),
             ):
                 mount_doc_cache = False
 
@@ -600,7 +602,8 @@ def _parse(self, output: str) -> None:
         return
 
     def _get_collection_plugins_details(
-        self, selected_collection: dict[str, Any]
+        self,
+        selected_collection: dict[str, Any],
     ) -> dict[str, Any]:
         """Get plugin details for the given collection.
 

src/ansible_navigator/actions/images.py

@@ -97,7 +97,10 @@ def color_menu(self, colno: int, colname: str, entry: dict[str, Any]) -> tuple[i
         return 2, 0
 
     def generate_content_heading(
-        self, obj: dict[Any, Any], screen_w: int, name: str = ""
+        self,
+        obj: dict[Any, Any],
+        screen_w: int,
+        name: str = "",
     ) -> CursesLines:
         """Create a heading for image content.
 
@@ -469,7 +472,7 @@ def _collect_image_list(self) -> None:
                 config_label_check = False
 
             image["execution_environment"] = any(
-                (legacy_check, root_label_check, config_label_check)
+                (legacy_check, root_label_check, config_label_check),
             )
         self._images.value = sorted(images, key=lambda i: i["name"])
 
@@ -574,7 +577,9 @@ def _run_runner(self, image_name: str) -> tuple[str, str, int]:
             kwargs.update({"container_options": self._args.container_options})
 
         self._logger.debug(
-            "Invoke runner with executable_cmd: %s and kwargs: %s", python_exec_path, kwargs
+            "Invoke runner with executable_cmd: %s and kwargs: %s",
+            python_exec_path,
+            kwargs,
         )
         _runner = Command(executable_cmd=python_exec_path, **kwargs)
         output, error, return_code = _runner.run()

src/ansible_navigator/command_runner/command_runner.py

@@ -79,7 +79,8 @@ def run_command(command: Command) -> None:
 
 
 def worker(
-    pending_queue: multiprocessing.Queue[Any], completed_queue: multiprocessing.Queue[Any]
+    pending_queue: multiprocessing.Queue[Any],
+    completed_queue: multiprocessing.Queue[Any],
 ) -> None:
     """Read pending, run, post process, and place in completed.
 

src/ansible_navigator/configuration_subsystem/definitions.py

@@ -472,7 +472,8 @@ class PaeChangeRequest:
 
 # A type used for the settings as a dictionary
 SettingsFileType = NewType(
-    "SettingsFileType", dict[str, bool | dict[Any, Any] | int | str | list[Any]]
+    "SettingsFileType",
+    dict[str, bool | dict[Any, Any] | int | str | list[Any]],
 )
 
 # A type used to describe a schema file for the settings

src/ansible_navigator/configuration_subsystem/navigator_post_processor.py

@@ -253,7 +253,9 @@ def display_color(
 
     @_post_processor
     def execution_environment(
-        self, entry: SettingsEntry, config: ApplicationConfiguration
+        self,
+        entry: SettingsEntry,
+        config: ApplicationConfiguration,
     ) -> PostProcessorReturn:
         # pylint: disable=too-many-locals
         """Post process execution_environment.
@@ -497,8 +499,9 @@ def _disable_pae_and_enforce_stdout(
             self._requested_mode.append(ModeChangeRequest(entry=entry.name, mode=mode))
             self._requested_pae.append(
                 PaeChangeRequest(
-                    entry=entry.name, playbook_artifact_enable=playbook_artifact_enable
-                )
+                    entry=entry.name,
+                    playbook_artifact_enable=playbook_artifact_enable,
+                ),
             )
             message = (
                 f"`{entry.name} requesting mode {mode.value} and pae as {playbook_artifact_enable}"
@@ -673,7 +676,7 @@ def lintables(
                 except subprocess.CalledProcessError:
                     exit_messages.append(
                         ExitMessage(
-                            message=("ansible-lint does not seem to be installed correctly.")
+                            message=("ansible-lint does not seem to be installed correctly."),
                         ),
                     )
                     exit_messages.append(
@@ -934,7 +937,8 @@ def playbook(entry: SettingsEntry, config: ApplicationConfiguration) -> PostProc
             exit_messages.append(ExitMessage(message=exit_msg, prefix=ExitPrefix.HINT))
             return messages, exit_messages
         if check_playbook_type(entry.value.current) == "file" and isinstance(
-            entry.value.current, str
+            entry.value.current,
+            str,
         ):
             entry.value.current = abs_user_path(entry.value.current)
         return messages, exit_messages

src/ansible_navigator/data/catalog_collections.py

@@ -356,7 +356,8 @@ def add_pseudo_builtin(self) -> None:
 
 
 def worker(
-    pending_queue: multiprocessing.Queue[Any], completed_queue: multiprocessing.Queue[Any]
+    pending_queue: multiprocessing.Queue[Any],
+    completed_queue: multiprocessing.Queue[Any],
 ) -> None:
     """Extract the documentation from a plugin, place in completed queue.
 
@@ -419,7 +420,8 @@ def worker(
 
 
 def identify_missing(
-    collections: dict[Any, Any], collection_cache: KeyValueStore
+    collections: dict[Any, Any],
+    collection_cache: KeyValueStore,
 ) -> tuple[set[Any], list[Any], int]:
     """Identify plugins missing from the cache.
 

src/ansible_navigator/data/image_introspect.py

@@ -163,7 +163,10 @@ def re_partition(content: Any, separator: str) -> Any:
         return key, delim, content
 
     def splitter(
-        self, lines: list[str], line_split: str, section_delim: str | None = None
+        self,
+        lines: list[str],
+        line_split: str,
+        section_delim: str | None = None,
     ) -> list[dict[str, Any]] | dict[str, Any]:
         """Split lines given a delimiter.
 
@@ -294,7 +297,9 @@ def commands(self) -> list[Command]:
         :returns: The defined command
         """
         pre = Command(
-            id_="pip_freeze", command="/usr/bin/python3 -m pip freeze", parse=self.parse_freeze
+            id_="pip_freeze",
+            command="/usr/bin/python3 -m pip freeze",
+            parse=self.parse_freeze,
         )
         run_command(pre)
         pre.parse(pre)

src/ansible_navigator/runner/command_async.py

@@ -20,7 +20,11 @@ class CommandAsync(CommandBase):
     """A wrapper for the asynchronous runner."""
 
     def __init__(
-        self, executable_cmd: str, queue: Queue[Any], write_job_events: bool, **kwargs: Any
+        self,
+        executable_cmd: str,
+        queue: Queue[Any],
+        write_job_events: bool,
+        **kwargs: Any,
     ) -> None:
         """Initialize the arguments for the ``run_command_async`` interface of ``ansible-runner``.
 

src/ansible_navigator/ui_framework/form.py

@@ -341,7 +341,8 @@ def _generate_messages(form_field: FieldWorking) -> CursesLines:
         return CursesLines(lines)
 
     def _generate_prompt(
-        self, form_field: FieldText | FieldChecks | FieldRadio
+        self,
+        form_field: FieldText | FieldChecks | FieldRadio,
     ) -> list[CursesLinePart]:
         """Generate the prompt for a field.
 

src/ansible_navigator/ui_framework/form_handler_options.py

@@ -50,7 +50,9 @@ def populate(self, form_field: FieldText, active: int) -> None:
                 text = option.text
             clp_text = CursesLinePart(len(option_code) + 1, text, color, decoration)
             self._add_line(
-                window=self.win, lineno=idx, line=CursesLine((clp_option_code, clp_text))
+                window=self.win,
+                lineno=idx,
+                line=CursesLine((clp_option_code, clp_text)),
             )
 
     def handle(self, idx: int, form_fields: list[FieldText]) -> tuple[FieldText, int]:

src/ansible_navigator/ui_framework/ui.py

@@ -814,7 +814,10 @@ def _get_heading_menu_items(
         return menu_heading, menu_items
 
     def _show_menu(
-        self, current: Sequence[Any], columns: list[str], await_input: bool
+        self,
+        current: Sequence[Any],
+        columns: list[str],
+        await_input: bool,
     ) -> Interaction:
         """Show a menu on the screen.
 

src/ansible_navigator/utils/print.py

@@ -112,7 +112,7 @@ def print_to_stdout(
                 content=content,
                 content_view=ContentView.NORMAL,
                 serialization_format=serialization_format,
-            )
+            ),
         )
         output = serialized
     else:

tests/conftest.py

@@ -392,7 +392,7 @@ def pytest_configure(config: pytest.Config) -> None:
     ):
         pytest.exit(
             f"Please remove or empty the ansible config file '{config_file}' "
-            "before testing, as this will likely break the test results."
+            "before testing, as this will likely break the test results.",
         )
 
     # look for ansible-navigator settings file
@@ -417,7 +417,8 @@ def pytest_unconfigure(config: pytest.Config) -> None:
 
 @pytest.fixture()
 def skip_if_already_failed(  # noqa: PT004
-    request: pytest.FixtureRequest, failed: set[str] = set()
+    request: pytest.FixtureRequest,
+    failed: set[str] = set(),
 ) -> Generator[None, None, None]:
     """Fixture that stops parametrized tests running on first failure."""
     key = request.node.name.split("[")[0]

tests/integration/_tmux_session.py

@@ -108,7 +108,9 @@ def _build_tmux_session(self) -> None:
                 break
             except libtmux.exc.LibTmuxException as exc:
                 warnings.warn(
-                    f"tmux session failure #{count}: {exc!s}", RuntimeWarning, stacklevel=2
+                    f"tmux session failure #{count}: {exc!s}",
+                    RuntimeWarning,
+                    stacklevel=2,
                 )
                 if count == tries:
                     raise

tests/integration/actions/builder/base.py

@@ -29,7 +29,8 @@ class BaseClass:
 
     @pytest.fixture(scope="module", name="tmux_session")
     def fixture_tmux_session(
-        self, request: pytest.FixtureRequest
+        self,
+        request: pytest.FixtureRequest,
     ) -> Generator[TmuxSession, None, None]:
         """Generate a tmux fixture for this module.
 

tests/integration/actions/config/base.py

@@ -50,7 +50,8 @@ class BaseClass:
 
     @pytest.fixture(scope="module", name="tmux_session")
     def fixture_tmux_session(
-        self, request: pytest.FixtureRequest
+        self,
+        request: pytest.FixtureRequest,
     ) -> Generator[TmuxSession, None, None]:
         """Generate a tmux fixture for this module.
 

tests/integration/actions/doc/test_welcome_interactive_ee.py

@@ -22,7 +22,12 @@
 testdata_lookup_doc = [
     pytest.param(0, CLI_LOOKUP_DOC, "welcome", "lookup_doc_pass", [], id="0"),
     pytest.param(
-        1, ":doc company_name.coll_1.lookup_1 -t lookup", "load doc", "lookup_doc_pass", [], id="1"
+        1,
+        ":doc company_name.coll_1.lookup_1 -t lookup",
+        "load doc",
+        "lookup_doc_pass",
+        [],
+        id="1",
     ),
 ]
 
@@ -32,7 +37,12 @@
 testdata_filter_doc = [
     pytest.param(0, CLI_FILTER_DOC, "welcome", "filter_doc_pass", [], id="0"),
     pytest.param(
-        1, ":doc company_name.coll_1.filter_1 -t filter", "load doc", "filter_doc_pass", [], id="1"
+        1,
+        ":doc company_name.coll_1.filter_1 -t filter",
+        "load doc",
+        "filter_doc_pass",
+        [],
+        id="1",
     ),
 ]
 

tests/integration/actions/doc/test_welcome_interactive_noee.py

@@ -22,7 +22,12 @@
 testdata_lookup_doc = [
     pytest.param(0, CLI_LOOKUP_DOC, "welcome", "lookup_doc_pass", [], id="0"),
     pytest.param(
-        1, ":doc company_name.coll_1.lookup_1 -t lookup", "load doc", "lookup_doc_pass", [], id="1"
+        1,
+        ":doc company_name.coll_1.lookup_1 -t lookup",
+        "load doc",
+        "lookup_doc_pass",
+        [],
+        id="1",
     ),
 ]
 
@@ -32,7 +37,12 @@
 testdata_filter_doc = [
     pytest.param(0, CLI_FILTER_DOC, "welcome", "filter_doc_pass", [], id="0"),
     pytest.param(
-        1, ":doc company_name.coll_1.filter_1 -t filter", "load doc", "filter_doc_pass", [], id="1"
+        1,
+        ":doc company_name.coll_1.filter_1 -t filter",
+        "load doc",
+        "filter_doc_pass",
+        [],
+        id="1",
     ),
 ]
 

tests/integration/actions/replay/test_welcome_interactive_ee.py

@@ -12,7 +12,11 @@
 testdata = [
     pytest.param(0, CLI, "welcome", ":help help", id="0"),
     pytest.param(
-        1, f":replay {PLAYBOOK_ARTIFACT}", "Play list", ["Complete", "Successful"], id="1"
+        1,
+        f":replay {PLAYBOOK_ARTIFACT}",
+        "Play list",
+        ["Complete", "Successful"],
+        id="1",
     ),
     pytest.param(2, ":0", "Task list", ":help help", id="2"),
     pytest.param(3, ":0", "Task 1", ":help help", id="3"),

tests/integration/actions/replay/test_welcome_interactive_noee.py

@@ -11,7 +11,11 @@
 testdata = [
     pytest.param(0, CLI, "welcome", ":help help", id="0"),
     pytest.param(
-        1, f":replay {PLAYBOOK_ARTIFACT}", "Play list", ["Complete", "Successful"], id="1"
+        1,
+        f":replay {PLAYBOOK_ARTIFACT}",
+        "Play list",
+        ["Complete", "Successful"],
+        id="1",
     ),
     pytest.param(2, ":0", "Task list", ":help help", id="2"),
     pytest.param(3, ":0", "Task 1", ":help help", id="3"),

tests/integration/actions/settings/base.py

@@ -48,7 +48,8 @@ class BaseClass:
 
     @pytest.fixture(scope="module", name="tmux_session")
     def fixture_tmux_session(
-        self, request: pytest.FixtureRequest
+        self,
+        request: pytest.FixtureRequest,
     ) -> Generator[TmuxSession, None, None]:
         """Tmux fixture for this module.