0042 to 0044

Author: claire-peters

coldfront/plugins/slurmrest/utils.py

@@ -57,7 +57,7 @@ def _call_api(self, api_func, *, noop=False, **api_kwargs):
 
     # account methods
     def get_account(self, account_name, with_assocs='true', with_coords='true'):
-        account = self.slurmdb_api.slurmdb_v0042_get_account(
+        account = self.slurmdb_api.slurmdb_v0044_get_account(
             account_name=account_name,
             with_assocs=with_assocs,
             with_coords=with_coords,
@@ -67,7 +67,7 @@ def get_account(self, account_name, with_assocs='true', with_coords='true'):
         return account.to_dict()
 
     def get_accounts(self, with_associations='true', with_coordinators='true'):
-        accounts = self.slurmdb_api.slurmdb_v0042_get_accounts(
+        accounts = self.slurmdb_api.slurmdb_v0044_get_accounts(
             with_associations=with_associations,
             with_coordinators=with_coordinators,
         )
@@ -84,12 +84,12 @@ def add_account(self, account_name, specs=None, noop=SLURMREST_NOOP):
         if specs is None:
             specs = []
         account_dict = {
-            'v0042_openapi_accounts_resp': {
+            'v0044_openapi_accounts_resp': {
                 'accounts': {'name': account_name, 'specs': specs}
             }
         }
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_post_accounts,
+            self.slurmdb_api.slurmdb_v0044_post_accounts,
             noop=noop,
             **account_dict
         )
@@ -102,15 +102,15 @@ def remove_account(self, account_name, noop=SLURMREST_NOOP):
         noop (bool, default False): if True, don't actually execute the action
         """
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_delete_account,
+            self.slurmdb_api.slurmdb_v0044_delete_account,
             noop=noop,
             **{'account_name': account_name}
         )
         logger.info('removed account: %s', response)
         return response
 
     def get_assocs(self):
-        associations = self.slurmdb_api.slurmdb_v0042_get_associations()
+        associations = self.slurmdb_api.slurmdb_v0044_get_associations()
         return associations.to_dict()
 
     # association methods
@@ -127,7 +127,7 @@ def get_assoc(self, *, user_name=None, account_name=None, assoc_id=None):
                 args['parent_account'] = 'root'
             else:
                 args['user'] = user_name
-        associations = self.slurmdb_api.slurmdb_v0042_get_association(**args)
+        associations = self.slurmdb_api.slurmdb_v0044_get_association(**args)
         return associations.to_dict()
 
     def post_assoc(self, account_name, user_name, change_dict, noop=SLURMREST_NOOP):
@@ -139,16 +139,16 @@ def post_assoc(self, account_name, user_name, change_dict, noop=SLURMREST_NOOP):
         for key, value in change_dict.items():
             associations[0][key] = value
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_post_associations,
+            self.slurmdb_api.slurmdb_v0044_post_associations,
             noop=noop,
-            **{'v0042_openapi_assocs_resp':{'associations': associations}}
+            **{'v0044_openapi_assocs_resp':{'associations': associations}}
         )
         logger.info('updated association: %s', response)
         return response
 
     def add_assoc(self, account_name, user_name, noop=SLURMREST_NOOP):
         association_dict = {
-            "v0042_openapi_assocs_resp": {
+            "v0044_openapi_assocs_resp": {
                 "associations": [{
                     'account': account_name,
                     'user': user_name,
@@ -157,7 +157,7 @@ def add_assoc(self, account_name, user_name, noop=SLURMREST_NOOP):
             }
         }
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_post_associations,
+            self.slurmdb_api.slurmdb_v0044_post_associations,
             noop=noop,
             **association_dict
         )
@@ -187,7 +187,7 @@ def remove_assoc(self, user_name=None, account_name=None, assoc_id=None, noop=SL
         args['cluster'] = self.active_cluster['name']
 
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_delete_association,
+            self.slurmdb_api.slurmdb_v0044_delete_association,
             noop=noop,
             **args
         )
@@ -197,55 +197,55 @@ def remove_assoc(self, user_name=None, account_name=None, assoc_id=None, noop=SL
 
     # config methods
     def get_config(self):
-        config = self.slurmdb_api.slurmdb_v0042_get_config()
+        config = self.slurmdb_api.slurmdb_v0044_get_config()
         if config.errors:
             raise Exception('error/s found in get_config output: %s', config.errors)
         return config.to_dict()
 
 
     # cluster methods
     def get_clusters(self):
-        clusters = self.slurmdb_api.slurmdb_v0042_get_clusters()
+        clusters = self.slurmdb_api.slurmdb_v0044_get_clusters()
         if clusters.errors:
             raise Exception('error/s found in get_clusters output: %s', clusters.errors)
         return clusters.to_dict()
 
     # license methods
     def get_licenses(self):
-        licenses = self.slurm_api.slurm_v0042_get_licenses()
+        licenses = self.slurm_api.slurm_v0044_get_licenses()
         if licenses.errors:
             raise Exception('error/s found in get_licenses output: %s', licenses.errors)
         return licenses.to_dict()
 
     # node methods
     def get_node(self, node_name):
-        node = self.slurm_api.slurm_v0042_get_node(node_name=node_name)
+        node = self.slurm_api.slurm_v0044_get_node(node_name=node_name)
         if node.errors:
             raise Exception('error/s found in get_node output: %s', node.errors)
         return node.to_dict()
 
     def get_nodes(self, update_time=None, flags=None):
-        nodes = self.slurm_api.slurm_v0042_get_nodes(update_time=update_time, flags=flags)
+        nodes = self.slurm_api.slurm_v0044_get_nodes(update_time=update_time, flags=flags)
         if nodes.errors:
             raise Exception('error/s found in get_nodes output: %s', nodes.errors)
         return nodes.to_dict()
 
 
     # partition methods
     def get_partitions(self, update_time=None, flags=None):
-        partitions = self.slurm_api.slurm_v0042_get_partitions(update_time=update_time, flags=flags)
+        partitions = self.slurm_api.slurm_v0044_get_partitions(update_time=update_time, flags=flags)
         return partitions.to_dict()
 
 
     # user methods
     def get_user(self, user_name):
-        user = self.slurmdb_api.slurmdb_v0042_get_user(user_name)
+        user = self.slurmdb_api.slurmdb_v0044_get_user(user_name)
         if user.errors:
             raise Exception('error/s found in get_user output: %s', user.errors)
         return user.to_dict()
 
     def get_users(self):
-        users = self.slurmdb_api.slurmdb_v0042_get_users()
+        users = self.slurmdb_api.slurmdb_v0044_get_users()
         if users.errors:
             raise Exception('error/s found in get_users output: %s', users.errors)
         return users.to_dict()
@@ -255,7 +255,7 @@ def update_user(self, user_name, change_dict, noop=SLURMREST_NOOP):
         for key, value in change_dict.items():
             user_dict[key] = value
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_post_users,
+            self.slurmdb_api.slurmdb_v0044_post_users,
             noop=noop,
             **user_dict
         )
@@ -266,14 +266,14 @@ def update_user(self, user_name, change_dict, noop=SLURMREST_NOOP):
     # qos methods
     def get_qos_list(self):
         """Get the list of QoS (Quality of Service) entries."""
-        qos_list = self.slurmdb_api.slurmdb_v0042_get_qos()
+        qos_list = self.slurmdb_api.slurmdb_v0044_get_qos()
         if qos_list.errors:
             raise Exception('error/s found in get_qos_list output: %s', qos_list.errors)
         return qos_list.to_dict()
 
     def get_qos(self, qos_name):
         """Get QoS entry by name."""
-        qos = self.slurmdb_api.slurmdb_v0042_get_single_qos(qos_name=qos_name)
+        qos = self.slurmdb_api.slurmdb_v0044_get_single_qos(qos_name=qos_name)
         if qos.errors:
             raise Exception('error/s found in get_qos output: %s', qos.errors)
         return qos.to_dict()
@@ -287,12 +287,12 @@ def add_or_update_qos(self, qos_name, specs=None, noop=SLURMREST_NOOP):
         if specs is None:
             specs = []
         qos_dict = {
-            'v0042_openapi_qos_resp': {
+            'v0044_openapi_qos_resp': {
                 'qos': {'name': qos_name, 'specs': specs}
             }
         }
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_post_qos,
+            self.slurmdb_api.slurmdb_v0044_post_qos,
             noop=noop,
             **qos_dict
         )
@@ -301,7 +301,7 @@ def add_or_update_qos(self, qos_name, specs=None, noop=SLURMREST_NOOP):
 
     def remove_qos(self, qos_name, noop=SLURMREST_NOOP):
         response = self._call_api(
-            self.slurmdb_api.slurmdb_v0042_delete_qos,
+            self.slurmdb_api.slurmdb_v0044_delete_qos,
             noop=noop,
             **{'qos': qos_name}
         )
@@ -314,15 +314,15 @@ def get_shares(self, accounts=None, users=None):
         accounts (string, default None): accounts for which to get shares
         users (string, default None): users for which to get shares
         """
-        shares = self.slurm_api.slurm_v0042_get_shares(accounts=accounts, users=users)
+        shares = self.slurm_api.slurm_v0044_get_shares(accounts=accounts, users=users)
         if shares.errors:
             raise Exception('error/s found in get_shares output: %s', shares.errors)
         return shares.to_dict()
 
 
     # wckey methods
     def get_wckeys(self):
-        wckeys = self.slurmdb_api.slurmdb_v0042_get_wckeys()
+        wckeys = self.slurmdb_api.slurmdb_v0044_get_wckeys()
         if wckeys.errors:
             raise Exception('error/s found in get_wckeys output: %s', wckeys.errors)
         return wckeys.to_dict()