Add additional tests

Author: jan-janssen

tests/test_cache_fileexecutor_serial.py

@@ -27,6 +27,10 @@ def list_files_in_working_directory():
     return os.listdir(os.getcwd())
 
 
+def get_error(a):
+    raise ValueError(a)
+
+
 @unittest.skipIf(
     skip_h5py_test, "h5py is not installed, so the h5py tests are skipped."
 )
@@ -68,6 +72,15 @@ def test_executor_working_directory(self):
             fs1 = exe.submit(list_files_in_working_directory)
             self.assertEqual(fs1.result(), os.listdir(cwd))
 
+    def test_executor_error(self):
+        cwd = os.path.join(os.path.dirname(__file__), "executables")
+        with FileExecutor(
+            resource_dict={"cwd": cwd}, execute_function=execute_in_subprocess
+        ) as exe:
+            fs1 = exe.submit(get_error, a=1)
+            with self.assertRaises(ValueError):
+                fs1.result()
+
     def test_executor_function(self):
         fs1 = Future()
         q = Queue()

tests/test_standalone_hdf.py

@@ -104,6 +104,21 @@ def test_hdf_queue_id(self):
         self.assertFalse(no_error)
         self.assertIsNone(output)
 
+    def test_hdf_error(self):
+        cache_directory = os.path.abspath("cache")
+        os.makedirs(cache_directory, exist_ok=True)
+        file_name = os.path.join(cache_directory, "test_error.h5")
+        error = ValueError()
+        dump(
+            file_name=file_name,
+            data_dict={"error": error},
+        )
+        flag, no_error, output = get_output(file_name=file_name)
+        self.assertTrue(get_runtime(file_name=file_name) == 0.0)
+        self.assertTrue(flag)
+        self.assertFalse(no_error)
+        self.assertTrue(isinstance(output, error.__class__))
+
     def tearDown(self):
         if os.path.exists("cache"):
             shutil.rmtree("cache")