diff --git a/tests/test_cache_fileexecutor_serial.py b/tests/test_cache_fileexecutor_serial.py index ffc92044..15b5bf44 100644 --- a/tests/test_cache_fileexecutor_serial.py +++ b/tests/test_cache_fileexecutor_serial.py @@ -4,6 +4,7 @@ import shutil import unittest from threading import Thread +from time import sleep try: from executorlib.task_scheduler.file.subprocess_spawner import ( @@ -214,6 +215,14 @@ def test_executor_function_dependence_args(self): q.put({"shutdown": True, "wait": True}) process.join() + def test_execute_in_subprocess(self): + process = execute_in_subprocess( + command=["sleep", "5"], + file_name="test.h5", + data_dict={"fn": sleep, "args": (5,)}, + ) + self.assertIsNone(terminate_subprocess(task=process)) + def test_execute_in_subprocess_errors(self): file_name = os.path.abspath(os.path.join(__file__, "..", "executorlib_cache", "test.h5")) os.makedirs(os.path.dirname(file_name))