Update for build_path error for monitor envs

Author: TimSVector

src/main/resources/scripts/parallel_full_reports.py

@@ -25,7 +25,7 @@ def runSingleAtgCommand(self, cmd):
             result = subprocess.run(atgCmd, shell=True, capture_output=True, text=True)
             return result.stdout.strip()
         except Exception as e:
-            return f'Error: {e}'
+            return "Error: " + e
 
 
 class RunFullReportsParallel(object):
@@ -50,11 +50,11 @@ def __init__(self):
             max_licenses = self.getLicenseCount()
             max_envs = self.getEnvCount()
 
-            print([max_cpus, max_licenses, max_envs])
+            #print([max_cpus, max_licenses, max_envs])
 
             self.max_concurrent = min([max_cpus,max_licenses, max_envs])
 
-            print("Using licensing max = ", self.max_concurrent)
+            #print("Using licensing max = ", self.max_concurrent)
         else:
             self.max_concurrent = int(args.jobs)
 
@@ -82,7 +82,6 @@ def getLicenseCount(self):
             cmd =  r'%VECTORCAST_DIR%\flexlm\lmutil lmstat -a -c %VECTOR_LICENSE_FILE% | findstr VECTORCAST_MANAGE:'
 
             result = subprocess.run(cmd, shell=True, capture_output=True, text=True)
-
             largest_available = 0
 
             for line in result.stdout.split("\n"):
@@ -93,7 +92,7 @@ def getLicenseCount(self):
                     if available > largest_available:
                         largest_available = available
 
-            print("Largest Available: ", largest_available)
+            #print("Largest Available: ", largest_available)
 
             return largest_available
 
@@ -111,7 +110,7 @@ def getLicenseCount(self):
             # Find DeviceSerialNumber
             FreeLicenses = root.find(".//FreeLicenses").text
 
-            print("FreeLicenses:", FreeLicenses)
+            #print("FreeLicenses:", FreeLicenses)
 
             return FreeLicenses
 
@@ -123,7 +122,10 @@ def generate_report(self, key):
 
         report_name = ""
 
-        build_dir = self.api.project.workspace + '/' + env.relative_working_directory
+        if env.definition.is_monitored:
+            build_dir = os.path.abspath(env.definition.original_environment_directory)
+        else:
+            build_dir = self.api.project.workspace + '/' + env.relative_working_directory
 
         if len(key.split("/")) != 3:
             comp, ts, group, env_name = key.split("/")
@@ -148,9 +150,9 @@ def generate_report(self, key):
 
             return result.stdout.strip()
         except Exception as e:
-            return f'Error: {e}'
+            return "Error: " + e
 
-        return f"Success: {report_name}: {result}"
+        return "Success: " + report_name + ": " + result
 
 
     def run(self):
@@ -163,7 +165,6 @@ def run(self):
         for future in concurrent.futures.as_completed(futures):
             try:
                 result = future.result()  # This raises the exception if one occurred
-                print(result)
             except Exception as e:
                 report_name = futures[future]
                 print("Exception in " + report_name + ": " + e)