Modify codecov concurrency mode from threading to multiprocessing

opendilab · Jan 13, 2023 · 906e0c0 · 906e0c0
1 parent a334a0c
commit 906e0c0
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/.coveragerc b/.coveragerc
@@ -1,4 +1,5 @@
 [run]
+concurrency = multiprocessing,thread
 omit =
   ding/utils/slurm_helper.py
   ding/utils/file_helper.py

diff --git a/ding/framework/middleware/tests/test_barrier.py b/ding/framework/middleware/tests/test_barrier.py
@@ -122,17 +122,23 @@ def test_star_topology_barrier():
     ctx = mp.get_context("spawn")
     with ctx.Pool(processes=4) as pool:
         pool.map(launch_barrier, [[i, 'star', star_barrier, 0] for i in range(4)])
+        pool.close()
+        pool.join()
 
 
 @pytest.mark.unittest
 def test_mesh_topology_barrier():
     ctx = mp.get_context("spawn")
     with ctx.Pool(processes=4) as pool:
         pool.map(launch_barrier, [[i, 'mesh', mesh_barrier, 1] for i in range(4)])
+        pool.close()
+        pool.join()
 
 
 @pytest.mark.unittest
 def test_unmatch_barrier():
     ctx = mp.get_context("spawn")
     with ctx.Pool(processes=4) as pool:
         pool.map(launch_barrier, [[i, 'mesh', unmatch_barrier, 2] for i in range(4)])
+        pool.close()
+        pool.join()