update(memory metrics): store in Mbs

myprogram.py

@@ -1,20 +1,11 @@
-import sys
-
 def cpu_heavy_task():
-    # Perform a computationally heavy task
     result = 0
     for i in range(10000000):
         result += i * i
 
-def memory_heavy_task():
-    # Allocate a large amount of memory
-    large_list = [0] * (1024**3 // 4)  # Allocate approximately 1GB of memory
-
 if __name__ == "__main__":
-    # Run CPU-heavy tasks
     for _ in range(10):
         cpu_heavy_task()
 
-    # Run Memory-heavy tasks
-    for _ in range(10):
-        memory_heavy_task()
+    large_list = [0] * (1024**3 // 4)  # Allocate approximately 1GB of memory
+

src/utils.rs

@@ -53,6 +53,7 @@ pub fn find_child_processes_recursive(system: &System, pid: Pid) -> Vec<Pid> {
     child_pids
 }
 
+// more info about /proc/PID/smaps file: https://shorturl.at/ituHO
 fn get_metric(pid: u32, metrics: &[&str]) -> io::Result<u64> {
     let path = format!("/proc/{}/smaps", pid);
     let file = File::open(&Path::new(&path))?;

src/workflow_executor.rs

@@ -801,8 +801,9 @@ Use the `--produce-script myscript.sh` option for this.";
                     .start_time
                     .map_or(0, |t| Instant::now().duration_since(t).as_millis() as i32);
 
-                total_uss = total_uss / 1024 / 1024;
-                total_pss = total_pss / 1024 / 1024;
+                // return uss and pss in Mbs (remember that uss is still in Kbs)
+                total_uss = total_uss / 1024;
+                total_pss = total_pss / 1024;
 
                 let nice_value = unsafe { 20 - getpriority(PRIO_PROCESS, pid) };
                 let mut task_resources: BTreeMap<&str, serde_json::Value> = BTreeMap::new();