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

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

Author: pre-commit-ci[bot]

robottelo/hosts.py

@@ -2660,10 +2660,14 @@ def generate_inventory_report(self, org, disconnected='false'):
             data={'disconnected': disconnected}
         )
         wait_for(
-            lambda: self.api.ForemanTask()
-            .search(query={'search': f'{generate_report_task} and started_at >= "{timestamp}"'})[0]
-            .result
-            == 'success',
+            lambda: (
+                self.api.ForemanTask()
+                .search(
+                    query={'search': f'{generate_report_task} and started_at >= "{timestamp}"'}
+                )[0]
+                .result
+                == 'success'
+            ),
             timeout=400,
             delay=15,
             silent_failure=True,
@@ -2674,10 +2678,12 @@ def sync_inventory_status(self, org):
         """Perform inventory sync"""
         inventory_sync = self.api.Organization(id=org.id).rh_cloud_inventory_sync()
         wait_for(
-            lambda: self.api.ForemanTask()
-            .search(query={'search': f'id = {inventory_sync["task"]["id"]}'})[0]
-            .result
-            == 'success',
+            lambda: (
+                self.api.ForemanTask()
+                .search(query={'search': f'id = {inventory_sync["task"]["id"]}'})[0]
+                .result
+                == 'success'
+            ),
             timeout=400,
             delay=15,
             silent_failure=True,

tests/foreman/api/test_discoveredhost.py

@@ -123,12 +123,14 @@ def _assert_discovered_host(host, channel=None, user_config=None):
     default_config = entity_mixins.DEFAULT_SERVER_CONFIG
     try:
         wait_for(
-            lambda: len(
-                host.api.DiscoveredHost(user_config or default_config).search(
-                    query={'search': f'name={host.guest_name}'}
+            lambda: (
+                len(
+                    host.api.DiscoveredHost(user_config or default_config).search(
+                        query={'search': f'name={host.guest_name}'}
+                    )
                 )
-            )
-            > 0,
+                > 0
+            ),
             timeout=20,
             delay=2,
             logger=logger,

tests/foreman/api/test_subscription.py

@@ -289,10 +289,12 @@ def parse(events):
     # Wait for candlepin to process the manifest upload events
     # Use polling instead of fixed sleep to avoid flakiness
     wait_for(
-        lambda: parse(
-            target_sat.api.Ping().search_json()['services']['candlepin_events']['message']
-        )['Processed']
-        > pre_processed_count,
+        lambda: (
+            parse(target_sat.api.Ping().search_json()['services']['candlepin_events']['message'])[
+                'Processed'
+            ]
+            > pre_processed_count
+        ),
         timeout=60,
         delay=5,
         handle_exception=True,

tests/foreman/cli/test_ansible.py

@@ -886,13 +886,15 @@ def test_positive_ansible_dynamic_inventory(
         )
         assert sync_response.ok
         wait_for(
-            lambda: rhel_contenthost.hostname
-            in [
-                host['name']
-                for host in aap_client.get(
-                    f'{api_base}inventories/{inv_list["results"][0]["id"]}/hosts/?search={rhel_contenthost.hostname}'
-                ).json()['results']
-            ],
+            lambda: (
+                rhel_contenthost.hostname
+                in [
+                    host['name']
+                    for host in aap_client.get(
+                        f'{api_base}inventories/{inv_list["results"][0]["id"]}/hosts/?search={rhel_contenthost.hostname}'
+                    ).json()['results']
+                ]
+            ),
             timeout=180,
             delay=30,
         )
@@ -1003,8 +1005,10 @@ def test_positive_ansible_provisioning_callback(
         # Host should do call back to the Satellite reporting
         # the result of the installation. Wait until Satellite reports that the host is installed.
         wait_for(
-            lambda: sat.cli.Host.info({'name': hostname})['status']['build-status']
-            != 'Pending installation',
+            lambda: (
+                sat.cli.Host.info({'name': hostname})['status']['build-status']
+                != 'Pending installation'
+            ),
             timeout=1800,
             delay=30,
         )
@@ -1038,13 +1042,15 @@ def test_positive_ansible_provisioning_callback(
         assert sync_response.ok
 
         wait_for(
-            lambda: hostname
-            in [
-                host['name']
-                for host in aap_client.get(
-                    f'{api_base}inventories/{inv_list["results"][0]["id"]}/hosts/?search={hostname}'
-                ).json()['results']
-            ],
+            lambda: (
+                hostname
+                in [
+                    host['name']
+                    for host in aap_client.get(
+                        f'{api_base}inventories/{inv_list["results"][0]["id"]}/hosts/?search={hostname}'
+                    ).json()['results']
+                ]
+            ),
             timeout=180,
             delay=30,
         )
@@ -1060,10 +1066,10 @@ def test_positive_ansible_provisioning_callback(
         # when the callback service is started, the job sometimes starts with pending or waiting state before going to the running state
         filtered_job = jobs['id'] if jobs['status'] in ('running', 'pending', 'waiting') else None
         wait_for(
-            lambda: aap_client.get(f'{api_base}jobs/?id={filtered_job}').json()['results'][0][
-                'status'
-            ]
-            == 'successful',
+            lambda: (
+                aap_client.get(f'{api_base}jobs/?id={filtered_job}').json()['results'][0]['status']
+                == 'successful'
+            ),
             timeout=120,
         )
         # Verify user rocket and package tmux is installed via ansible-callback on provisioning host

tests/foreman/cli/test_artifacts.py

@@ -116,13 +116,17 @@ def test_positive_artifact_repair(
             repo=module_synced_content.repo.label,
         )
         wait_for(
-            lambda: len(
-                get_repo_files_urls_by_url(
-                    sat_repo_url,
-                    extension='rpm' if module_synced_content.repo.content_type == 'yum' else 'iso',
+            lambda: (
+                len(
+                    get_repo_files_urls_by_url(
+                        sat_repo_url,
+                        extension='rpm'
+                        if module_synced_content.repo.content_type == 'yum'
+                        else 'iso',
+                    )
                 )
-            )
-            > 0,
+                > 0
+            ),
             timeout=120,
             delay=15,
         )

tests/foreman/cli/test_computeresource_vmware.py

@@ -142,8 +142,10 @@ def test_positive_provision_end_to_end(
     # check if vm is created on vmware
     assert vmwareclient.does_vm_exist(hostname) is True
     wait_for(
-        lambda: sat.cli.Host.info({'name': hostname})['status']['build-status']
-        != 'Pending installation',
+        lambda: (
+            sat.cli.Host.info({'name': hostname})['status']['build-status']
+            != 'Pending installation'
+        ),
         timeout=1800,
         delay=30,
     )
@@ -234,8 +236,10 @@ def test_positive_image_provision_end_to_end(
         assert 'VirtualTPM' in vm.get_virtual_device_type_names()
 
     wait_for(
-        lambda: sat.cli.Host.info({'name': hostname})['status']['build-status']
-        != 'Pending installation',
+        lambda: (
+            sat.cli.Host.info({'name': hostname})['status']['build-status']
+            != 'Pending installation'
+        ),
         timeout=1800,
         delay=30,
     )

tests/foreman/cli/test_discoveredhost.py

@@ -55,12 +55,14 @@ def test_rhel_pxe_discovery_provisioning(
     org = provisioning_hostgroup.organization[0].read()
     loc = provisioning_hostgroup.location[0].read()
     wait_for(
-        lambda: sat.api.DiscoveredHost().search(
-            query={
-                'mac': mac,
-            }
-        )
-        != [],
+        lambda: (
+            sat.api.DiscoveredHost().search(
+                query={
+                    'mac': mac,
+                }
+            )
+            != []
+        ),
         timeout=1500,
         delay=20,
     )
@@ -143,12 +145,14 @@ def test_rhel_pxeless_discovery_provisioning(
     org = provisioning_hostgroup.organization[0].read()
     loc = provisioning_hostgroup.location[0].read()
     wait_for(
-        lambda: sat.api.DiscoveredHost().search(
-            query={
-                'mac': mac,
-            }
-        )
-        != [],
+        lambda: (
+            sat.api.DiscoveredHost().search(
+                query={
+                    'mac': mac,
+                }
+            )
+            != []
+        ),
         timeout=1500,
         delay=40,
     )

tests/foreman/cli/test_host.py

@@ -1732,12 +1732,14 @@ def test_positive_erratum_applicability(
     # Verify that the applied erratum is no longer in applicable errata list
     try:
         applicable_erratum, _ = wait_for(
-            lambda: security_errata
-            not in [
-                errata['erratum-id']
-                for errata in target_sat.cli.Host.errata_list({'host-id': host_info['id']})
-                if errata['installable'] == 'true'
-            ],
+            lambda: (
+                security_errata
+                not in [
+                    errata['erratum-id']
+                    for errata in target_sat.cli.Host.errata_list({'host-id': host_info['id']})
+                    if errata['installable'] == 'true'
+                ]
+            ),
             handle_exception=True,
             timeout=300,
             delay=5,

tests/foreman/cli/test_leapp_client.py

@@ -28,8 +28,9 @@
         {'source_version': RHEL8_VER, 'target_version': RHEL9_VER},
         {'source_version': RHEL9_VER, 'target_version': RHEL10_VER},
     ],
-    ids=lambda upgrade_path: f'{upgrade_path["source_version"]}'
-    f'_to_{upgrade_path["target_version"]}',
+    ids=lambda upgrade_path: (
+        f'{upgrade_path["source_version"]}_to_{upgrade_path["target_version"]}'
+    ),
 )
 @pytest.mark.parametrize('auth_type', ['admin', 'non-admin'])
 def test_positive_leapp_upgrade_rhel(
@@ -114,8 +115,9 @@ def test_positive_leapp_upgrade_rhel(
     [
         {'source_version': RHEL8_VER, 'target_version': RHEL9_VER},
     ],
-    ids=lambda upgrade_path: f'{upgrade_path["source_version"]}'
-    f'_to_{upgrade_path["target_version"]}',
+    ids=lambda upgrade_path: (
+        f'{upgrade_path["source_version"]}_to_{upgrade_path["target_version"]}'
+    ),
 )
 @pytest.mark.parametrize(
     'setting_update',

tests/foreman/cli/test_remoteexecution.py

@@ -959,12 +959,14 @@ def test_recurring_with_unreachable_host(self, module_target_sat, rhel_contentho
         )
         # wait for the third task to be planned which verifies the BZ
         wait_for(
-            lambda: int(
-                cli.RecurringLogic.info(
-                    {'id': cli.JobInvocation.info({'id': invocation.id})['recurring-logic-id']}
-                )['task-count']
-            )
-            > 2,
+            lambda: (
+                int(
+                    cli.RecurringLogic.info(
+                        {'id': cli.JobInvocation.info({'id': invocation.id})['recurring-logic-id']}
+                    )['task-count']
+                )
+                > 2
+            ),
             timeout=180,
             delay=10,
         )