show log per sample

Author: msarkis-icr

pages/run_pipeline.py

@@ -40,7 +40,8 @@ def reset_button_state():
 # Create the selectbox and update session state
 pipeline_options = ["select"] + list(map_pipeline_project.keys())
 index = pipeline_options.index(PIPELINE)
-PIPELINE = st.selectbox("Select a pipeline", options=pipeline_options, index=index)  # , key="PIPELINE")
+PIPELINE = st.selectbox("Select a pipeline", options=pipeline_options, index=index)
+adapt_samples = False
 # adding "select" as the first and default choice
 if PIPELINE != "select":
     project_options = list(map_pipeline_project[PIPELINE].keys())
@@ -74,7 +75,6 @@ def reset_button_state():
             st.write("Your custom samples:", custom_sample_list)
             ss_set("custom_sample_list", custom_sample_list)
 
-    adapt_samples = False
     if(map_pipeline_project[PIPELINE][PROJECT]["adapt_samples"]):
         adapt_samples = st.checkbox("Adapt samples prior to running nextflow", 
                             value=False,

shared/command_helper.py

@@ -38,15 +38,13 @@ def pipe_cmd(
     def get_pipeline_command():
         """Generate the pipeline execution command based on the sample selection."""
         path_to_script = get_path_to_script(selected_pipeline, selected_project, selected_samples)
-
-        # not sure if this is the best thing-using job id for filenamne
-        log_out = f"{work_dir}/logs/%j.out"
-        log_err = f"{work_dir}/logs/%j.err"
 
         args = []
         base_cmd = f"bash {path_to_script}" #default
 
         if selected_samples == "demo":
+            log_out = f"{work_dir}/logs/log_demo.out"
+            log_err = f"{work_dir}/logs/log_demo.err"
             base_cmd = f"sbatch -o {log_out} -e {log_err}"
             args += [path_to_script, work_dir, output_dir]
 
@@ -64,7 +62,8 @@ def get_pipeline_command():
                 args += ["--adapt-samples"]
             if bed_file:
                 args += ["--bed", bed_file]
-
+        
+        # note: I use logs/log_{samplename} for sample logs
         preamble = f"""
         mkdir -p {work_dir}/logs
         cd {work_dir}

tabs/tab_command.py

@@ -11,7 +11,7 @@ def tab(
     MY_SSH,
     selected_pipeline,
     selected_project,
-    selected_samples="all",
+    selected_samples="",
     work_dir="work",
     output_dir="output",
     custom_sample_list=[],
@@ -21,7 +21,7 @@ def tab(
 ):
     # --- Initialize session state ---
     st.session_state.setdefault("username", username)
-    st.session_state.setdefault("JOB_ID", "17379785")
+    st.session_state.setdefault("JOB_ID", "")
     st.session_state.setdefault("run_pipeline_clicked", False)
 
     # --- Display username input ---
@@ -77,17 +77,21 @@ def run_nextflow():
         if st.session_state["JOB_ID"]:
             st.success(f"Running Job ID: {st.session_state['JOB_ID']}")
 
+    get_sample_list = lambda selected_samples, custom_sample_list: [selected_samples] if selected_samples == 'demo' else custom_sample_list
+    parsed_sample_list = get_sample_list(selected_samples, custom_sample_list)
     # --- Logs tab ---
     with tabL:
+        # when checking logs, ask user to select one (drop-down list) of his samples at a time : demo or customised sample
         if st.button("Get Logs"):
-            # st.write("📦 session_state:", dict(st.session_state))
-            job_id = st.session_state.get("JOB_ID")
-            st.write("📌 Accessed JOB_ID:", job_id)  # DEBUG
-            if not job_id:
+            _sample_to_log = st.selectbox("Choose an option", parsed_sample_list)
+            st.write("You selected:", _sample_to_log)
+            #job_id = st.session_state.get("JOB_ID")
+            #st.write("📌 Accessed JOB_ID:", job_id)  # DEBUG
+            if not _sample_to_log:
                 st.error("No job was launched yet")
             else:
-                log_out = f"{work_dir}/logs/{job_id}.out"
-                log_err = f"{work_dir}/logs/{job_id}.err"
+                log_out = f"{work_dir}/logs/log_{_sample_to_log}.out"
+                log_err = f"{work_dir}/logs/log_{_sample_to_log}.err"
                 tO, tE = st.tabs(["Output", "Error"])
                 outputO, outputE = tO.empty(), tE.empty()
                 with st.spinner("Fetching logs..."):