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

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

Author: pre-commit-ci[bot]

.github/workflows/codeql.yml

@@ -5,9 +5,9 @@ name: "CodeQL"
 
 on:
   push:
-    branches: [ "master", "1.0", "1.1", "1.2", "1.3", "1.4", "1.5", "1.6", "1.7" ]
+    branches: ["master", "1.0", "1.1", "1.2", "1.3", "1.4", "1.5", "1.6", "1.7"]
   pull_request:
-    branches: [ "master" ]
+    branches: ["master"]
   schedule:
     - cron: "59 17 * * 6"
 
@@ -23,7 +23,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        language: [ python ]
+        language: [python]
 
     steps:
       - name: Checkout

src/decisionengine_modules/AWS/transforms/AwsBurnRate.py

@@ -17,7 +17,6 @@ def __init__(self, config):
         super().__init__(config)
 
     def transform(self, data_block):
-
         spot_prices = self.provisioner_resource_spot_prices(data_block).fillna(0)
         occupancy = self.AWS_Occupancy(data_block).fillna(0)
 

src/decisionengine_modules/GCE/transforms/GceFigureOfMerit.py

@@ -22,7 +22,6 @@ def __init__(self, config):
         super().__init__(config)
 
     def transform(self, data_block):
-
         self.logger.debug("in GceFigureOfMerit transform")
         performance = self.GCE_Instance_Performance(data_block)
         performance["PricePerformance"] = np.where(

src/decisionengine_modules/glideinwms/classads.py

@@ -5,7 +5,6 @@
 
 
 class GlideClientClassad(classadSupport.Classad):
-
     # Class variable: Counter for classad counter.
     # key = (name)
     classad_counter = {}

src/decisionengine_modules/glideinwms/configure_gwms_frontend.py

@@ -84,7 +84,6 @@ def get_arg_parser():
 ############################################################
 
 if __name__ == "__main__":
-
     noroot_msg = "NOTE: Executing this command as user root is not allowed. Use the decisionengine user instead."
 
     if os.geteuid() == 0:

src/decisionengine_modules/glideinwms/glide_frontend_element.py

@@ -436,7 +436,6 @@ def create_glideclient_classads(
         entry_name="condor",
         glidein_site="Unknown",
     ):
-
         if glidein_params is None:
             glidein_params = {}
         if glidein_monitors is None:
@@ -664,7 +663,7 @@ def create_glideclientglobal_classads(self, glidefactory_classad, key_builder):
         }
         for cred in credentials:
             if cred.advertize:
-                for (fname, data) in cred.loaded_data:
+                for fname, data in cred.loaded_data:
                     classad_attrs_to_encrypt[cred.file_id(fname)] = data
                     if hasattr(cred, "security_class"):
                         # Convert security_class to string for factory
@@ -935,7 +934,7 @@ def count_match(self, job_types, job_type, entries):
             # Get group of jobs based on request cpus
             job_groups = jobs.groupby("RequestCpus")
 
-            for (req_cpus, group) in job_groups:
+            for req_cpus, group in job_groups:
                 # Group jobs by matching criteria: RequestCpus for now
                 # We care about job counts for each group
                 job_count = len(group)
@@ -1059,7 +1058,6 @@ def identify_limits_triggered(
         global_total_idle_glideins,
         limits_triggered,
     ):
-
         # Identify the limits triggered for advertising in glideresource
         if count_status["Total"] >= self.entry_max_glideins:  # max_running
             limits_triggered[
@@ -1117,7 +1115,6 @@ def compute_glidein_min_idle(
             or (global_total_glideins >= self.global_total_max_slots)
             or (global_total_idle_glideins >= self.global_total_max_slots_idle)
         ):
-
             # Do not request more glideins under following conditions:
             # 1. Have all the running jobs I wanted
             # 2. Have enough idle vms/slots
@@ -1793,7 +1790,7 @@ def count_match_fom_bff(self, job_types, job_type, entries):
 
             dbg_info.append(f"{len(job_groups)} job groups")
 
-            for (req_cpus, job_group) in job_groups:
+            for req_cpus, job_group in job_groups:
                 # Group jobs by matching criteria: RequestCpus for now
                 # We only care about job counts for each group
                 job_count = len(job_group)
@@ -1897,7 +1894,7 @@ def count_match_fom_dff(self, job_types, job_type, entries):
             # Get group of jobs based on request cpus
             job_groups = jobs.groupby("RequestCpus")
 
-            for (req_cpus, job_group) in job_groups:
+            for req_cpus, job_group in job_groups:
                 # Group jobs by matching criteria: RequestCpus for now
                 # We care about job counts for each group
                 job_count = len(job_group)
@@ -1934,7 +1931,7 @@ def count_match_fom_dff(self, job_types, job_type, entries):
                     # Start with entries with lowest FOM and fill them first
                     job_count_matched = 0
 
-                    for (_fom, fom_group_entries) in fom_matches:
+                    for _fom, fom_group_entries in fom_matches:
                         job_count_unmatched = job_count - job_count_matched
                         if job_count_unmatched > 0:
                             # Distribute the jobs equally among this entry group

src/decisionengine_modules/glideinwms/security.py

@@ -227,7 +227,6 @@ def __str__(self):
 
 
 class CredentialCache:
-
     # Cache the credential ids so we do not create again unless required
     # Specially expensive to create id for proxy which uses DN in hash
     def __init__(self):

src/decisionengine_modules/glideinwms/transforms/gwms_to_aws_data.py

@@ -20,7 +20,6 @@ def __init__(self, config):
         super().__init__(config)
 
     def transform(self, datablock):
-
         # Get the dataframe containing AWS entries
         self.logger.debug("in AWSFactoryEntryData transform")
         aws_entries = self.Factory_Entries(datablock).xs("AWS")

src/decisionengine_modules/glideinwms/transforms/job_clustering.py

@@ -49,7 +49,6 @@ def __init__(self, config):
         )
 
     def transform(self, datablock):
-
         self.logger.info("*** Starting job clustering ***")
         # TODO not sure if metadata is propagated or if this is the right attrs to id a datablock