@@ -38,9 +38,7 @@ def time_multiprocessing(num_workers: int) -> float:
3838 return time () - start_time
3939
4040 time_1_cpu = time_multiprocessing (num_workers = 1 )
41- print (f"time_1_cpu = { time_1_cpu } " )
4241 time_2_cpu = time_multiprocessing (num_workers = 2 )
43- print (f"time_2_cpu = { time_2_cpu } " )
4442
4543 assert time_2_cpu < time_1_cpu
4644
@@ -55,7 +53,6 @@ def cpu_intensive_batch(da: DocumentArray[MyMatrix]) -> DocumentArray[MyMatrix]:
5553
5654
5755def test_apply_batch_multiprocessing ():
58- print (f"os.cpu_count() = { os .cpu_count ()} " )
5956 if os .cpu_count () > 1 :
6057
6158 def time_multiprocessing (num_workers : int ) -> float :
@@ -74,9 +71,7 @@ def time_multiprocessing(num_workers: int) -> float:
7471 return time () - start_time
7572
7673 time_1_cpu = time_multiprocessing (num_workers = 1 )
77- print (f"time_1_cpu = { time_1_cpu } " )
7874 time_2_cpu = time_multiprocessing (num_workers = 2 )
79- print (f"time_2_cpu = { time_2_cpu } " )
8075
8176 assert time_2_cpu < time_1_cpu
8277
@@ -98,9 +93,7 @@ def time_multithreading(num_workers: int) -> float:
9893 return time () - start_time
9994
10095 time_1_thread = time_multithreading (num_workers = 1 )
101- print (f"time_1_thread = { time_1_thread } " )
10296 time_2_thread = time_multithreading (num_workers = 2 )
103- print (f"time_2_thread = { time_2_thread } " )
10497
10598 assert time_2_thread < time_1_thread
10699
@@ -129,8 +122,6 @@ def time_multithreading_batch(num_workers: int) -> float:
129122 return time () - start_time
130123
131124 time_1_thread = time_multithreading_batch (num_workers = 1 )
132- print (f"time_1_thread = { time_1_thread } " )
133125 time_2_thread = time_multithreading_batch (num_workers = 2 )
134- print (f"time_2_thread = { time_2_thread } " )
135126
136127 assert time_2_thread < time_1_thread
0 commit comments