- Version 2.14.x

Author: afabiani

.gitignore

@@ -1,8 +1,14 @@
 *.py[cod]
 *.suo
 
+/build/
 RemoteWPS1.pyproj
 RemoteWPS1.sln
-Include
-Lib/
-Scripts/
+/Include
+/Lib/
+/Scripts/
+
+/RemoteWPS.pyproj
+/RemoteWPS.sln
+/.vs/config/applicationhost.config
+/dist/

setup.py

@@ -33,7 +33,7 @@
 
 setup(
     name = "wps-remote",
-    version = "2.12.0",
+    version = "2.14.0",
     author = "GeoServer Developers",
     author_email = "geoserver-devel@lists.sourceforge.net",
     description = "A library that allows users to publish their executables as GeoServer WPS Processes through the XMPP protocol",

src/wps_remote.egg-info/PKG-INFO

@@ -75,10 +75,16 @@ def __init__(self, remote_config_filepath, service_config_filepath, execute_mess
 
         self._executable_path = serviceConfig.get("DEFAULT", "executable_path")
         self._executable_cmd = serviceConfig.get("DEFAULT", "executable_cmd")
+        if not os.path.isabs(self._executable_path):
+            full_executable_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), self._executable_path)
+            self._executable_cmd = self._executable_cmd.replace(self._executable_path, full_executable_path)
+            self._executable_path = full_executable_path
 
         self._stdout_parser = serviceConfig.get_list("Logging", "stdout_parser")
         self._stdout_action = serviceConfig.get_list("Logging", "stdout_action")
         self._output_dir =  serviceConfig.get_path("DEFAULT", "output_dir")
+        if not os.path.isabs(self._output_dir):
+            self._output_dir = os.path.join(os.path.dirname(os.path.abspath(__file__)), self._output_dir)
         self._max_running_time = datetime.timedelta(seconds = serviceConfig.getint("DEFAULT", "max_running_time_seconds"))
 
         #create the concrete uploader object

src/wps_remote.egg-info/SOURCES.txt

@@ -20,6 +20,7 @@
 import logging
 import traceback
 
+
 class Resource(object):
     """
     Identify a process generated by a remote WPS call.

src/wps_remote.egg-info/dependency_links.txt

@@ -35,27 +35,31 @@ def __init__(self, load_average_scan_minutes):
         ResourceMonitor.lock.release()
 
     def proc_is_running(self, proc_names):
-        for proc in psutil.process_iter(): 
-        
-            process = psutil.Process(proc.pid).as_dict() # Get the process info using PID
-
-            pid    = str(process["pid"])
-            ppid   = str(process["ppid"])
-            status = process["status"]
-
-            cpu_percent = process["cpu_percent"]
-            mem_percent = process["memory_percent"]
-        
-            rss = str(process["memory_info"].rss)
-            vms = str(process["memory_info"].vms)
-            username = process["username"]
-            name = process["name"] # Here is the process name
-            path = process["cwd"]
-
-            for proc_name in proc_names:
-                if status.lower() == "running" and proc_name in name.lower():
-                    return True
-
+        for proc in psutil.process_iter():
+            try:
+                process = psutil.Process(proc.pid).as_dict() # Get the process info using PID
+
+                pid    = str(process["pid"])
+                ppid   = str(process["ppid"])
+                status = process["status"]
+
+                cpu_percent = process["cpu_percent"]
+                mem_percent = process["memory_percent"]
+
+                rss = str(process["memory_info"].rss)
+                vms = str(process["memory_info"].vms)
+                username = process["username"]
+                name = process["name"] # Here is the process name
+                path = process["cwd"]
+
+                for proc_name in proc_names:
+                    if status.lower() == "running" and proc_name in name.lower():
+                        return True
+            except:
+                import traceback
+                tb = traceback.format_exc()
+                # print(tb)
+                continue
         return False
 
     def run(self):