Merge pull request #80 from george0st/changes

Bug fixing, add unit test

qgate_perf/version.py

@@ -1,3 +1,3 @@
 # Store the version here so:
 
-__version__ = '0.4.39'
+__version__ = '0.4.40'

tests/test_internal.py

@@ -4,7 +4,7 @@
 from qgate_perf.parallel_executor import ParallelExecutor
 from qgate_perf.parallel_probe import ParallelProbe
 from qgate_perf.run_setup import RunSetup
-from qgate_perf.helper import ExecutorHelper
+from qgate_perf.helper import ExecutorHelper, get_readable_duration
 from qgate_perf.run_return import RunReturn
 from qgate_perf.standard_deviation import StandardDeviation
 from pympler import asizeof
@@ -73,9 +73,9 @@ def test_size(self):
     def test_readable_time(self):
         exec = ParallelExecutor(None)
 
-        print(exec._readable_duration(100))
-        print(exec._readable_duration(100.45))
-        print(exec._readable_duration(5004.45))
+        print(get_readable_duration(100))
+        print(get_readable_duration(100.45))
+        print(get_readable_duration(5004.45))
 
     def test_precison(self):
         text_format="{:<05}"

tests/test_perf_partly.py

@@ -106,3 +106,27 @@ def test_basic2(self):
 
         self.assertTrue(perf[1].executor_process == 4 and perf[1].executor_thread == 1)
         self.assertTrue(perf[1][1].avrg < 1 and perf[1][0.9].avrg < 1)
+
+    def test_basic3(self):
+        generator = ParallelExecutor(prf_partly,
+                                     label="prf_partly",
+                                     detail_output=True,
+                                     output_file=path.join(self.OUTPUT_ADR, "perf_partly.txt"),
+                                     init_each_bulk=True)
+
+
+        setup = RunSetup(duration_second=0, start_delay=0, parameters={"percentile": 0.50})
+        perf = generator.run_bulk_executor(bulk_list=[[1,10]],
+                                    executor_list=[[2,1], [4,1]],
+                                    run_setup=setup,
+                                    performance_detail=True)
+
+        self.assertTrue(perf.state)
+        self.assertTrue(perf[0].bundle_row == 1 and perf[0].bundle_col == 10)
+        self.assertTrue(perf[1].bundle_row == 1 and perf[1].bundle_col == 10)
+
+        self.assertTrue(perf[0].executor_process == 2 and perf[0].executor_thread == 1)
+        self.assertTrue(perf[0][1].avrg < 1 and perf[0][0.5].avrg < 1)
+
+        self.assertTrue(perf[1].executor_process == 4 and perf[1].executor_thread == 1)
+        self.assertTrue(perf[1][1].avrg < 1 and perf[1][0.5].avrg < 1)