feat(api): add kubernetes_queue to API client (#504)

Closes reanahub/reana-job-controller#493

Author: CameronMcClymont

AUTHORS.md

@@ -9,6 +9,7 @@ The list of contributors in alphabetical order:
 - [Audrius Mecionis](https://orcid.org/0000-0002-3759-1663)
 - [Bruno Rosendo](https://orcid.org/0000-0002-0923-3148)
 - [Burt Holzman](https://orcid.org/0000-0001-5235-6314)
+- [Cameron McClymont](https://orcid.org/0009-0002-0176-5251)
 - [Camila Diaz](https://orcid.org/0000-0001-5543-797X)
 - [Clemens Lange](https://orcid.org/0000-0002-3632-3157)
 - [Daan Rosendal](https://orcid.org/0000-0002-3447-9000)

reana_commons/api_client.py

@@ -100,6 +100,7 @@ def submit(  # noqa: C901
         kerberos=False,
         kubernetes_uid=None,
         kubernetes_memory_limit=None,
+        kubernetes_queue=None,
         unpacked_img=False,
         voms_proxy=False,
         rucio=False,
@@ -129,6 +130,7 @@ def submit(  # noqa: C901
         :param rucio: Decides if a rucio environment should be provided for job.
         :param kubernetes_uid: Overwrites the default user id in the job container.
         :param kubernetes_memory_limit: Overwrites the default memory limit in the job container.
+        :param kubernetes_queue: Kueue LocalQueue to submit the job to.
         :param unpacked_img: Decides if unpacked iamges should be used.
         :param htcondor_max_runtime: Maximum runtime of a HTCondor job.
         :param htcondor_accounting_group: Accounting group of a HTCondor job.
@@ -169,6 +171,9 @@ def submit(  # noqa: C901
         if kubernetes_memory_limit:
             job_spec["kubernetes_memory_limit"] = kubernetes_memory_limit
 
+        if kubernetes_queue:
+            job_spec["kubernetes_queue"] = kubernetes_queue
+
         if kubernetes_job_timeout is not None:
             job_spec["kubernetes_job_timeout"] = kubernetes_job_timeout
 

reana_commons/openapi_specifications/reana_job_controller.json

@@ -85,6 +85,9 @@
         "kubernetes_memory_limit": {
           "type": "string"
         },
+        "kubernetes_queue": {
+          "type": "string"
+        },
         "kubernetes_uid": {
           "format": "int32",
           "type": "integer"

reana_commons/openapi_specifications/reana_server.json

@@ -2,7 +2,7 @@
   "info": {
     "description": "Submit workflows to be run on REANA Cloud",
     "title": "REANA Server",
-    "version": "0.95.0a2"
+    "version": "0.95.0a3"
   },
   "paths": {
     "/account/settings/linkedaccounts/": {},
@@ -500,6 +500,17 @@
                   "title": "Default memory limit for Kubernetes jobs",
                   "value": "3Gi"
                 },
+                "kueue_available_queues": {
+                  "title": "List of local queues available for batch job processing",
+                  "value": [
+                    "local-queue-1",
+                    "local-queue-2"
+                  ]
+                },
+                "kueue_enabled": {
+                  "title": "Whether Kueue is enabled for batch job processing",
+                  "value": "False"
+                },
                 "maximum_kubernetes_jobs_timeout": {
                   "title": "Maximum timeout for Kubernetes jobs",
                   "value": "1209600"
@@ -750,6 +761,31 @@
                   },
                   "type": "object"
                 },
+                "kueue_available_queues": {
+                  "properties": {
+                    "title": {
+                      "type": "string"
+                    },
+                    "value": {
+                      "items": {
+                        "type": "string"
+                      },
+                      "type": "array"
+                    }
+                  },
+                  "type": "object"
+                },
+                "kueue_enabled": {
+                  "properties": {
+                    "title": {
+                      "type": "string"
+                    },
+                    "value": {
+                      "type": "string"
+                    }
+                  },
+                  "type": "object"
+                },
                 "maximum_interactive_session_inactivity_period": {
                   "properties": {
                     "title": {

reana_commons/validation/schemas/reana_analysis_schema.json

@@ -316,6 +316,11 @@
                       "title": "Kubernetes memory limit",
                       "description": "Kubernetes memory limit (e.g. 256Mi - read more about the expected memory values on the official Kubernetes documentation: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/#meaning-of-memory)"
                     },
+                    "kubernetes_queue": {
+                      "type": "string",
+                      "title": "Kubernetes queue",
+                      "description": "The Kubernetes queue to submit the job to, e.g. the name of a remote Kubernetes cluster."
+                    },
                     "name": {
                       "type": "string",
                       "title": "Step name"