fix(sessions): get the session status from the pod state (reanahub#611)

Closes reanahub/reana-ui#408

Author: Alputer

reana_workflow_controller/k8s.py

@@ -477,3 +477,20 @@ def delete_dask_dashboard_ingress(cluster_name, workflow_id):
         plural="middlewares",
         name=f"replacepath-{workflow_id}",
     )
+
+
+def check_pod_by_prefix(pod_name_prefix, namespace="default"):
+    """Check if there is a Pod in the given namespace whose name starts with the specified prefix. We assume that there exists 0 or 1 pod with a given prefix."""
+    try:
+        pods = current_k8s_corev1_api_client.list_namespaced_pod(namespace=namespace)
+
+        for pod in pods.items:
+            if pod.metadata.name.startswith(pod_name_prefix):
+                if pod.status.phase == "Running":
+                    return "Running"
+                else:
+                    return "Not Ready"
+
+        return "Not Found"
+    except ApiException as e:
+        return f"Error: {e.reason}"

reana_workflow_controller/rest/workflows.py

@@ -22,6 +22,7 @@
 from webargs import fields, validate
 from webargs.flaskparser import use_args, use_kwargs
 from reana_commons.config import WORKFLOW_TIME_FORMAT
+from reana_commons.utils import build_unique_component_name
 from reana_db.database import Session
 from reana_db.models import RunStatus, User, UserWorkflow, Workflow, WorkflowResource
 from reana_db.utils import (
@@ -48,6 +49,8 @@
     use_paginate_args,
 )
 
+from reana_workflow_controller.k8s import check_pod_by_prefix
+
 START = "start"
 STOP = "stop"
 DELETED = "deleted"
@@ -398,7 +401,20 @@ def get_workflows(args, paginate=None):  # noqa
                 if int_session:
                     workflow_response["session_type"] = int_session.type_.name
                     workflow_response["session_uri"] = int_session.path
+                    int_session_pod_name_prefix = build_unique_component_name(
+                        "run-session", int_session.workflow[0].id_
+                    )
+                    if int_session.status == RunStatus.created:
+                        pod_status = check_pod_by_prefix(
+                            pod_name_prefix=int_session_pod_name_prefix
+                        )
+                        if pod_status == "Running":
+                            int_session.status = RunStatus.running
+                            db_session = Session.object_session(int_session)
+                            db_session.commit()
+
                     workflow_response["session_status"] = int_session.status.name
+
                 # Skip workflow if type is interactive and there is no session
                 elif type_ == "interactive":
                     continue