Fix typos and stylecheck

broker/helpers.py

@@ -201,7 +201,7 @@ def resolve_file_args(broker_args):
             if data := load_file(val):
                 final_args.update({key: data})
             else:
-                final_arg.update({key: val})
+                final_args.update({key: val})
         else:
             final_args.update({key: val})
     return final_args
@@ -599,9 +599,9 @@ def __getstate__(self):
         try:
             self._purify()
         except RecursionError:
-                logger.warning(f"Recursion limit reached on {self._purify_target}")
-                self.__dict__[self._purify_target] = None
-                self.__getstate__()
+            logger.warning(f"Recursion limit reached on {self._purify_target}")
+            self.__dict__[self._purify_target] = None
+            self.__getstate__()
         self.__dict__.pop("_purify_target", None)
         return self.__dict__
 

broker/providers/ansible_tower.py

@@ -13,7 +13,7 @@
 
 try:
     import awxkit
-except:
+except ImportError:
     raise exceptions.ProviderError(
         provider="AnsibleTower", message="Unable to import awxkit. Is it installed?"
     )
@@ -342,7 +342,7 @@ def _get_expire_date(self, host_id):
                 .expire_date
             )
             return str(datetime.fromtimestamp(int(time_stamp)))
-        except:
+        except Exception:
             return None
 
     def _compile_host_info(self, host):
@@ -372,7 +372,7 @@ def _compile_host_info(self, host):
                     host_info["_broker_args"]["workflow"] = host.get_related(
                         "last_job"
                     ).summary_fields.source_workflow_job.name
-                except:
+                except Exception:
                     logger.warning(
                         f"Unable to determine workflow for {host_info['hostname']}"
                     )
@@ -619,7 +619,7 @@ def nick_help(self, **kwargs):
             logger.warning("That action is not yet implemented.")
 
     def release(self, name, broker_args=None):
-        if broker_args == None:
+        if broker_args is None:
             broker_args = {}
         return self.execute(
             workflow=settings.ANSIBLETOWER.release_workflow,

broker/settings.py

@@ -34,7 +34,7 @@
     validators=validators,
 )
 # to make doubly sure, remove the vault loader if set somehow
-settings._loaders = [loader for loader in settings._loaders if not "vault" in loader]
+settings._loaders = [loader for loader in settings._loaders if "vault" not in loader]
 
 try:
     settings.validators.validate()

tests/functional/test_satlab.py

@@ -72,6 +72,7 @@ def test_tower_host():
         res = r_host.execute("ls /tmp/fake")
         assert "broker_settings.yaml" in res.stdout
 
+
 def test_tower_host_mp():
     with Broker(workflow="deploy-base-rhel", _count=3) as r_hosts:
         for r_host in r_hosts:

tests/providers/test_container.py

@@ -1,4 +1,3 @@
-from asyncio import QueueEmpty
 import json
 import pytest
 from broker.broker import Broker

tests/test_helpers.py

@@ -87,10 +87,10 @@ def test_find_origin_simple():
     origin = helpers.find_origin()
     assert len(origin) == 2
     assert origin[0].startswith("test_find_origin")
-    assert origin[1] == None
+    assert origin[1] is None
 
 
-def test_find_origin_fixture(basic_origin):
+def test_find_origin_fixture_basic(basic_origin):
     assert basic_origin[0].startswith("basic_origin")