feat(manager): add user-uuid label to runtime batch pods (#665)

Also amend Dask runtime pods to use the same label instead of
previously-used one.

Closes #664

Author: CameronMcClymont

.gitignore

@@ -68,3 +68,6 @@ target/
 
 # Visual Studio Code files
 .vscode
+
+# PyCharm files
+.idea

reana_workflow_controller/dask.py

@@ -160,7 +160,7 @@ def _prepare_cluster(self):
         self.cluster_body["metadata"] = {
             "name": self.cluster_name,
             "labels": {
-                "reana-run-dask-owner-uuid": self.user_id,
+                "user-uuid": self.user_id,
                 "reana-run-dask-workflow-uuid": self.workflow_id,
             },
         }
@@ -233,7 +233,7 @@ def _prepare_autoscaler(self):
         self.autoscaler_body["metadata"] = {
             "name": self.autoscaler_name,
             "labels": {
-                "reana-run-dask-owner-uuid": self.user_id,
+                "user-uuid": self.user_id,
                 "reana-run-dask-workflow-uuid": self.workflow_id,
             },
         }
@@ -706,7 +706,7 @@ def create_dask_dashboard_ingress(workflow_id, user_id):
                 workflow_id, "dashboard_ingress_middleware"
             ),
             "labels": {
-                "reana-run-dask-owner-uuid": user_id,
+                "user-uuid": user_id,
                 "reana-run-dask-workflow-uuid": workflow_id,
             },
             "namespace": REANA_RUNTIME_KUBERNETES_NAMESPACE,
@@ -729,7 +729,7 @@ def create_dask_dashboard_ingress(workflow_id, user_id):
                 "traefik.ingress.kubernetes.io/router.middlewares": f"{REANA_RUNTIME_KUBERNETES_NAMESPACE}-{get_dask_component_name(workflow_id, 'dashboard_ingress_middleware')}@kubernetescrd",
             },
             labels={
-                "reana-run-dask-owner-uuid": user_id,
+                "user-uuid": user_id,
                 "reana-run-dask-workflow-uuid": workflow_id,
             },
         ),

reana_workflow_controller/k8s.py

@@ -170,7 +170,7 @@ def _build_deployment(self, metadata):
             "app": self.deployment_name,
             "reana_workflow_mode": "session",
             "reana-run-session-workflow-uuid": str(self.workflow_id),
-            "reana-run-session-owner-uuid": str(self.owner_id),
+            "user-uuid": str(self.owner_id),
         }
         template = client.V1PodTemplateSpec(
             metadata=client.V1ObjectMeta(labels=labels),

reana_workflow_controller/workflow_run_manager.py

@@ -634,6 +634,7 @@ def _create_job_spec(
         labels = {
             "reana_workflow_mode": "batch",
             "reana-run-batch-workflow-uuid": str(self.workflow.id_),
+            "user-uuid": owner_id,
         }
 
         if KUEUE_ENABLED: