Skip to content

Commit 701dfb7

Browse files
authored
[BugFix] Fix flaky test by waiting for procs instead of sleep (#306)
1 parent a5a37cc commit 701dfb7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

test/test_transforms.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,8 @@ def test_vecnorm_parallel_auto(nprc):
219219
for idx in range(nprc):
220220
queues[idx][1].put(msg)
221221

222-
# sleep(0.01)
222+
for p in prcs:
223+
p.join()
223224
obs_sum = td.get("next_observation_sum").clone()
224225
obs_ssq = td.get("next_observation_ssq").clone()
225226
obs_count = td.get("next_observation_count").clone()

0 commit comments

Comments
 (0)