Release v0.9.3: Add PBS environment variable support and update documentation

Author: ForblazeProject

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "fbqueue"
-version = "0.9.2"
+version = "0.9.3"
 edition = "2021"
 
 [dependencies]

Cargo.toml

@@ -181,11 +181,27 @@ FBQueue automatically maps embedded script directives to internal job parameters
 | **Dependencies** | `#$ -hold_jid 123` | **`depend`** |
 | **Walltime** | `#$ -l h_rt=01:30:00` | **`walltime`** |
 
-## 9. Roadmap
+## 9. Job Environment Variables (PBS Compatibility)
+
+FBQueue automatically injects environment variables into the job execution context to ensure compatibility with scripts designed for traditional HPC schedulers like PBS.
+
+| Variable | Description |
+| :--- | :--- |
+| **`$PBS_JOBID`** | The unique job ID assigned by FBQueue (e.g., `147`). |
+| **`$PBS_JOBNAME`** | The name of the job (defaults to the script path if not specified). |
+| **`$PBS_O_WORKDIR`** | The absolute path to the directory where the job was submitted. |
+| **`$PBS_QUEUE`** | The name of the queue where the job is executing. |
+| **`$PBS_NODEFILE`** | Path to a temporary file containing the execution hostname. Deleted after job completion. |
+| **`$PBS_ENVIRONMENT`** | Set to `PBS_BATCH` to indicate the job is running in a batch environment. |
+| **`$PBS_O_HOST`** | The hostname of the machine where the job was submitted. |
+| **`$PBS_O_LOGNAME`** | The username of the user who submitted the job. |
+
+## 10. Roadmap
 
 *   [x] **Background Archiving**: Automatic `tar.gz` compression of old job records during idle periods.
-*   *   **Flexible Directory Discovery**: Support for recursive parent directory search for `.fbqueue` configuration.
-*   *   **Detailed Analytics**: Advanced statistics and status summaries via `fbqueue stat`.
+*   [x] **Full PBS Compatibility**: Support for standard environment variables and script directives.
+*   [x] **Windows Native Execution**: Support for `.ps1` and `.bat` scripts with automatic path handling.
+*   [ ] **Detailed Analytics**: Advanced statistics and status summaries via `fbqueue stat`.
 
 ---
 ### Author

MANUAL.md

@@ -83,7 +83,22 @@ Job id            Name             User              Time Use S Queue
 
 ---
 
-## 4. Why use FBQueue for PBS Workflows?
+## 4. Standard PBS Environment Variables
+
+FBQueue injects standard PBS environment variables into your job's execution context. This allows your scripts to remain portable across different clusters.
+
+| Variable | Description |
+| :--- | :--- |
+| **`$PBS_JOBID`** | The unique job ID assigned by FBQueue. |
+| **`$PBS_O_WORKDIR`** | The directory from which the job was submitted. |
+| **`$PBS_NODEFILE`** | Path to a file containing the hostname of the execution node. |
+| **`$PBS_O_HOST`** | The hostname of the submission machine. |
+| **`$PBS_O_LOGNAME`** | The username of the user who submitted the job. |
+| **`$PBS_ENVIRONMENT`** | Set to `PBS_BATCH` to indicate a batch job environment. |
+
+---
+
+## 5. Why use FBQueue for PBS Workflows?
 
 - **Personal Sandbox**: Run your PBS scripts on your local workstation or a shared server where you don't have administrative rights to a full PBS cluster.
 - **Portability**: Move your research scripts between a massive supercomputer and your local laptop without changing a single line of the `#PBS` directives.

PBS_COMPATIBILITY.md

@@ -31,7 +31,7 @@ Download the pre-built static binary and place it in your `$PATH`:
 
 ```bash
 # 1. Download
-wget https://github.com/ForblazeProject/fbqueue/releases/download/v0.9.2/fbqueue-linux-x64.tar.gz
+wget https://github.com/ForblazeProject/fbqueue/releases/download/v0.9.3/fbqueue-linux-x64.tar.gz
 
 # 2. Extract and move
 tar -xzvf fbqueue-linux-x64.tar.gz
@@ -81,6 +81,11 @@ fbqueue sub ./calc.sh
 
 ## 📜 Change Log
 
+### v0.9.3
+- **Full PBS Environment Emulation**: Jobs now automatically define standard PBS variables like `$PBS_JOBID`, `$PBS_O_WORKDIR`, `$PBS_O_HOST`, and `$PBS_O_LOGNAME`.
+- **Nodefile Support**: Dynamically generates and cleans up `$PBS_NODEFILE` for compatibility with scripts expecting a list of execution nodes.
+- **Improved Metadata Accuracy**: Enhanced hostname and user detection across both Linux and Windows for more reliable job logging.
+
 ### v0.9.2
 - **Fixed Process Leak**: Improved job cancellation logic using process groups (`setsid`) on Unix and tree termination (`/T`) on Windows. Subprocesses spawned by job scripts are now correctly terminated.
 - **Robust Job Filtering**: `qstat <jobID>` (and `stat <jobID>`) now works reliably even if the job has already finished and moved to history. It also correctly handles the `.master` suffix.

README.md

@@ -69,7 +69,8 @@ pub fn run_daemon() {
             for entry in entries.filter_map(|e| e.ok()) {
                 let id = entry.file_name().to_str().unwrap().trim_end_matches(".job").to_string();
                 if let Some(pos) = running_jobs.iter().position(|(rid, _, _, _, _, _)| rid == &id) {
-                    let (_, mut child, _, _, _, _) = running_jobs.remove(pos);
+                    let (rid, mut child, _, _, _, _) = running_jobs.remove(pos);
+                    let _ = fs::remove_file(fbq_dir.join("run").join(format!("nodefile.{}", rid)));
                     kill_process_tree(&mut child);
                     if let Ok(mut f) = fs::OpenOptions::new().append(true).open(fbq_dir.join("queue/running").join(entry.file_name())) {
                         let _ = writeln!(f, "status: CANCELLED");
@@ -87,6 +88,7 @@ pub fn run_daemon() {
                 if now - *start_at > wt {
                     kill_process_tree(child);
                     let (job_id, _, _, _, _, _) = running_jobs.remove(i);
+                    let _ = fs::remove_file(fbq_dir.join("run").join(format!("nodefile.{}", job_id)));
                     let fname = format!("{}.job", job_id);
                     let job_path = fbq_dir.join("queue/running").join(&fname);
                     if let Ok(mut f) = fs::OpenOptions::new().append(true).open(&job_path) {
@@ -103,6 +105,8 @@ pub fn run_daemon() {
         while i < running_jobs.len() {
             if let Ok(Some(status)) = running_jobs[i].1.try_wait() {
                 let (id, _, _, _, _, _) = running_jobs.remove(i);
+                let nodefile_path = fbq_dir.join("run").join(format!("nodefile.{}", id));
+                let _ = fs::remove_file(nodefile_path);
                 let fname = format!("{}.job", id);
                 let rpath = fbq_dir.join("queue/running").join(&fname);
                 let exit_code = status.code().unwrap_or(-1);
@@ -202,7 +206,17 @@ pub fn run_daemon() {
                                 process::Command::new(&j.cmd)
                             };
 
-                            child_cmd.args(&j.args).current_dir(&j.cwd).envs(j.envs).stdout(out_f).stderr(err_f);
+                            let nodefile_path = fbq_dir.join("run").join(format!("nodefile.{}", j.id));
+                            let hostname = process::Command::new("hostname").output().map(|o| String::from_utf8_lossy(&o.stdout).trim().to_string()).unwrap_or_else(|_| "localhost".to_string());
+                            let _ = fs::write(&nodefile_path, format!("{}\n", hostname));
+
+                            child_cmd.args(&j.args).current_dir(&j.cwd).envs(j.envs)
+                                .env("PBS_JOBID", &j.id)
+                                .env("PBS_JOBNAME", &j.name)
+                                .env("PBS_QUEUE", &j.queue)
+                                .env("PBS_NODEFILE", nodefile_path.display().to_string())
+                                .env("PBS_ENVIRONMENT", "PBS_BATCH")
+                                .stdout(out_f).stderr(err_f);
 
                             if let Ok(child) = child_cmd.spawn() {
                                 running_jobs.push((j.id, child, j.cost, j.queue, now, j.walltime));

src/daemon.rs

@@ -104,7 +104,7 @@ pub fn handle_daemon(args: &[String]) {
             if let Ok(pid_str) = fs::read_to_string(&lock_file) {
                 if let Ok(pid) = pid_str.trim().parse::<u32>() {
                     #[cfg(unix)] { process::Command::new("kill").arg(pid.to_string()).status().ok(); }
-                    #[cfg(windows)] { process::Command::new("taskkill").arg("/PID").arg(pid.to_string()).arg("/F").status().ok(); }
+                    #[cfg(windows)] { process::Command::new("taskkill").arg("/PID").arg(pid.to_string()).arg("/F").arg("/T").status().ok(); }
                 }
             }
             let _ = fs::remove_file(lock_file);

src/handlers.rs

@@ -1,5 +1,6 @@
 use std::env;
 use std::fs;
+use std::process;
 use std::io::{self, BufRead};
 use std::path::{Path, PathBuf};
 use crate::utils;
@@ -162,6 +163,7 @@ pub fn submit_job(cmd_tmpl: &str, args_tmpl: &[String], cwd: &Path, val: Option<
     let job_file_path = fbq_dir.join("queue/new").join(format!("{}.job", job_id));
 
     let current_user = env::var("USER").or_else(|_| env::var("USERNAME")).unwrap_or_else(|_| "unknown".to_string());
+    let hostname = process::Command::new("hostname").output().map(|o| String::from_utf8_lossy(&o.stdout).trim().to_string()).unwrap_or_else(|_| "localhost".to_string());
 
     let mut content = format!("id: {}\nname: {}\ncmd: {}\ncost: {}\nuser: {}\nqueue: {}\n", job_id, final_name, cmd, final_cost, current_user, final_queue);
     if let Some(o) = final_out { content.push_str(&format!("stdout: {}\n", o)); }
@@ -172,6 +174,12 @@ pub fn submit_job(cmd_tmpl: &str, args_tmpl: &[String], cwd: &Path, val: Option<
 
     for arg in job_args { content.push_str(&format!("arg: {}\n", arg)); }
     content.push_str(&format!("cwd: {}\n", cwd.display()));
+
+    // PBS compatibility environment variables (Submission time)
+    content.push_str(&format!("env: PBS_O_WORKDIR={}\n", cwd.display()));
+    content.push_str(&format!("env: PBS_O_LOGNAME={}\n", current_user));
+    content.push_str(&format!("env: PBS_O_HOST={}\n", hostname));
+
     for (key, val) in env::vars() { content.push_str(&format!("env: {}={}\n", key, val)); }
 
         fs::write(&job_file_path, content).expect("Failed to write job file");

src/job.rs

@@ -0,0 +1,4 @@
+capacity: 8
+default_queue: batch
+queue: batch
+  priority: 10

tests/tmp/case_1/config

@@ -0,0 +1,51 @@
+id: 1
+name: echo
+cmd: echo
+cost: 1
+user: wsl
+queue: batch
+arg: Hello FBQueue
+cwd: /home/wsl/dev/queue/fbqueue/tests/tmp/work_1
+env: SHELL=/bin/bash
+env: WSL2_GUI_APPS_ENABLED=1
+env: TERM_PROGRAM_VERSION=3.2a
+env: WSL_DISTRO_NAME=Ubuntu
+env: TMUX=/tmp/tmux-1000/default,1066,0
+env: FBQUEUE_DIR=/home/wsl/dev/queue/fbqueue/tests/tmp/case_1
+env: NAME=Lenovo2
+env: PWD=/home/wsl/dev/queue/fbqueue/tests/tmp/work_1
+env: LOGNAME=wsl
+env: JIRA_API_TOKEN=ATATT3xFfGF0CBC73AekZT98GiCQlo0ERk36caSu8WrwQtM7vDeEFoVj9FaD5noJaAbjBwBmhxxw4SbeRKLMniw-zXhz9aGIu9d0yWiLn1OYk3h622z3LNDZDks8evpKaYHJ60aQoJp4p7KRu3KEebqqY16jVrqc-5aa8jFHc9QgBRBkqzMM6rE=C3808572
+env: MOTD_SHOWN=update-motd
+env: HOME=/home/wsl
+env: MSI2LMP_LIBRARY=/usr/share/lammps/frc_files
+env: LANG=C.UTF-8
+env: WSL_INTEROP=/run/WSL/405_interop
+env: LS_COLORS=rs=0:di=01;34:ln=01;36:mh=00:pi=40;33:so=01;35:do=01;35:bd=40;33;01:cd=40;33;01:or=40;31;01:mi=00:su=37;41:sg=30;43:ca=30;41:tw=30;42:ow=34;42:st=37;44:ex=01;32:*.tar=01;31:*.tgz=01;31:*.arc=01;31:*.arj=01;31:*.taz=01;31:*.lha=01;31:*.lz4=01;31:*.lzh=01;31:*.lzma=01;31:*.tlz=01;31:*.txz=01;31:*.tzo=01;31:*.t7z=01;31:*.zip=01;31:*.z=01;31:*.dz=01;31:*.gz=01;31:*.lrz=01;31:*.lz=01;31:*.lzo=01;31:*.xz=01;31:*.zst=01;31:*.tzst=01;31:*.bz2=01;31:*.bz=01;31:*.tbz=01;31:*.tbz2=01;31:*.tz=01;31:*.deb=01;31:*.rpm=01;31:*.jar=01;31:*.war=01;31:*.ear=01;31:*.sar=01;31:*.rar=01;31:*.alz=01;31:*.ace=01;31:*.zoo=01;31:*.cpio=01;31:*.7z=01;31:*.rz=01;31:*.cab=01;31:*.wim=01;31:*.swm=01;31:*.dwm=01;31:*.esd=01;31:*.jpg=01;35:*.jpeg=01;35:*.mjpg=01;35:*.mjpeg=01;35:*.gif=01;35:*.bmp=01;35:*.pbm=01;35:*.pgm=01;35:*.ppm=01;35:*.tga=01;35:*.xbm=01;35:*.xpm=01;35:*.tif=01;35:*.tiff=01;35:*.png=01;35:*.svg=01;35:*.svgz=01;35:*.mng=01;35:*.pcx=01;35:*.mov=01;35:*.mpg=01;35:*.mpeg=01;35:*.m2v=01;35:*.mkv=01;35:*.webm=01;35:*.webp=01;35:*.ogm=01;35:*.mp4=01;35:*.m4v=01;35:*.mp4v=01;35:*.vob=01;35:*.qt=01;35:*.nuv=01;35:*.wmv=01;35:*.asf=01;35:*.rm=01;35:*.rmvb=01;35:*.flc=01;35:*.avi=01;35:*.fli=01;35:*.flv=01;35:*.gl=01;35:*.dl=01;35:*.xcf=01;35:*.xwd=01;35:*.yuv=01;35:*.cgm=01;35:*.emf=01;35:*.ogv=01;35:*.ogx=01;35:*.aac=00;36:*.au=00;36:*.flac=00;36:*.m4a=00;36:*.mid=00;36:*.midi=00;36:*.mka=00;36:*.mp3=00;36:*.mpc=00;36:*.ogg=00;36:*.ra=00;36:*.wav=00;36:*.oga=00;36:*.opus=00;36:*.spx=00;36:*.xspf=00;36:
+env: WAYLAND_DISPLAY=wayland-0
+env: LAMMPS_POTENTIALS=/usr/share/lammps/potentials
+env: LESSCLOSE=/usr/bin/lesspipe %s %s
+env: TERM=xterm-256color
+env: LESSOPEN=| /usr/bin/lesspipe %s
+env: USER=wsl
+env: GIT_PAGER=cat
+env: TMUX_PANE=%4
+env: DISPLAY=:0
+env: SHLVL=4
+env: PAGER=cat
+env: XDG_RUNTIME_DIR=/run/user/1000/
+env: GEMINI_CLI=1
+env: WSLENV=
+env: GEMINI_CLI_NO_RELAUNCH=true
+env: XDG_DATA_DIRS=/usr/local/share:/usr/share:/var/lib/snapd/desktop
+env: PATH=/home/wsl/.local/bin:/home/wsl/.local/qe/bin:/home/wsl/.local/bin:/home/wsl/.local/bin:/home/wsl/.cargo/bin:/home/wsl/.local/qe/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/usr/games:/usr/local/games:/usr/lib/wsl/lib:/mnt/c/Program Files/Microsoft MPI/Bin/:/mnt/c/WINDOWS/system32:/mnt/c/WINDOWS:/mnt/c/WINDOWS/System32/Wbem:/mnt/c/WINDOWS/System32/WindowsPowerShell/v1.0/:/mnt/c/WINDOWS/System32/OpenSSH/:/mnt/c/Program Files/Go/bin:/mnt/c/Program Files/dotnet/:/mnt/c/Program Files/CMake/bin:/mnt/c/Program Files (x86)/Windows Kits/10/Windows Performance Toolkit/:/mnt/c/Program Files/nodejs/:/mnt/c/Program Files/Git/cmd:/mnt/c/Users/sat_i/.cargo/bin:/mnt/c/Python311:/mnt/c/Python311/Scripts:/mnt/c/Users/sat_i/AppData/Local/Microsoft/WindowsApps:/mnt/c/Program Files (x86)/Vim/vim90:/mnt/c/BURAI1.3.2_Windows/exec.WIN/qe:/mnt/c/Program Files/mopac-22.1.0-win/bin:/mnt/c/Program Files/MOPAC/bin:/mnt/c/Users/sat_i/AppData/Roaming/Python/Python311/Scripts:/mnt/c/Users/sat_i/AppData/Local/Programs/Microsoft VS Code/bin:/mnt/c/Users/sat_i/go/bin:/mnt/c/Qt/6.9.2/msvc2022_64/bin:/mnt/c/Program Files/VTK/bin:/mnt/c/Program Files/LAMMPS 64-bit 22Jul2025 with GUI/bin:/mnt/c/Users/sat_i/AppData/Roaming/npm:/mnt/c/Program Files/jira_1.7.0_windows_x86_64/bin:/snap/bin:/home/wsl/installer/jira_1.7.0_linux_x86_64/bin:/usr/local/go/bin:/home/wsl/installer/jira_1.7.0_linux_x86_64/bin:/usr/local/go/bin
+env: DBUS_SESSION_BUS_ADDRESS=unix:path=/run/user/1000/bus
+env: HOSTTYPE=x86_64
+env: PULSE_SERVER=unix:/mnt/wslg/PulseServer
+env: OLDPWD=/home/wsl/dev/queue/fbqueue
+env: TERM_PROGRAM=tmux
+env: _=./qsub
+start_at: 1772025603
+end_at: 1772025604
+exit_code: 0
+status: DONE