Catch FileNotFoundError exception

When we want to find some Postgres process in testgres psutils lib first gets list of all system processes (children() function in testgres's auxiliary_processes). Next testgres asks for process name (cmdline() function), so psutils goes to /proc/pid/ in Linux. In case any of processes listed in previous step, we get FileNotFoundError

Author: Sofia Kopikova

testgres/enums.py

@@ -1,5 +1,6 @@
 from enum import Enum, IntEnum
 from six import iteritems
+from psutil import NoSuchProcess
 
 
 class XLogMethod(Enum):
@@ -68,11 +69,15 @@ def from_process(process):
             ],
         }  # yapf: disable
 
+        try:
+            cmdline = ''.join(process.cmdline())
+        except (FileNotFoundError, ProcessLookupError, NoSuchProcess):
+            return ProcessType.Unknown
+
         # we deliberately cut special words and spaces
-        cmdline = ''.join(process.cmdline()) \
-                    .replace('postgres:', '', 1) \
-                    .replace('bgworker:', '', 1) \
-                    .replace(' ', '')
+        cmdline = cmdline.replace('postgres:', '', 1) \
+            .replace('bgworker:', '', 1) \
+            .replace(' ', '')
 
         for ptype in ProcessType:
             if cmdline.startswith(ptype.value.replace(' ', '')):

tests/test_simple.py

@@ -9,6 +9,7 @@
 import time
 import six
 import unittest
+import psutil
 
 import logging.config
 
@@ -48,6 +49,7 @@
 # NOTE: those are ugly imports
 from testgres import bound_ports
 from testgres.utils import PgVer
+from testgres.node import ProcessProxy
 
 
 def pg_version_ge(version):
@@ -965,6 +967,18 @@ def test_child_pids(self):
                 with self.assertRaises(TestgresException):
                     replica.source_walsender
 
+    def test_child_process_dies(self):
+        # test for FileNotFound exception during child_processes() function
+        with subprocess.Popen(["sleep", "60"]) as process:
+            self.assertEqual(process.poll(), None)
+            # collect list of processes currently running
+            children = psutil.Process(os.getpid()).children()
+            # kill a process, so received children dictionary becomes invalid
+            process.kill()
+            process.wait()
+            # try to handle children list -- missing processes will have ptype "ProcessType.Unknown"
+            [ProcessProxy(p) for p in children]
+
 
 if __name__ == '__main__':
     if os.environ.get('ALT_CONFIG'):