|
@@ -234,6 +234,7 @@ def compute_mean_std(averagers, unbiased=True):
|
|
|
return means, stds
|
|
|
|
|
|
|
|
|
+@pytest.mark.skip(reason="Skipped until finishing a more stable averager implementation (TODO @justheuristic)")
|
|
|
@pytest.mark.forked
|
|
|
def test_allreduce_grid():
|
|
|
dht_instances = launch_dht_instances(8)
|
|
@@ -256,7 +257,7 @@ def test_allreduce_grid():
|
|
|
|
|
|
for i in range(5):
|
|
|
time.sleep(0.2)
|
|
|
- # FIXME (@justheuristic): An averager does not have time to update the key in GroupKeyManager
|
|
|
+ # FIXME: An averager does not have time to update the key in GroupKeyManager
|
|
|
# if .step() is called without any delays
|
|
|
|
|
|
step_futures = [averager.step(wait=False) for averager in averagers]
|
|
@@ -382,10 +383,9 @@ def test_too_few_peers():
|
|
|
averager.shutdown()
|
|
|
|
|
|
|
|
|
-# TODO(@justheuristic): Finish the elasticity_0.0.1 branch and make this test work
|
|
|
@pytest.mark.skip(
|
|
|
reason="The current implementation of elasticity (multi-stage averaging for the case when "
|
|
|
- "num_peers > ~3 * target_group_size) is incorrect"
|
|
|
+ "num_peers > ~3 * target_group_size) is incorrect (TODO @justheuristic)"
|
|
|
)
|
|
|
@pytest.mark.forked
|
|
|
def test_overcrowded(num_peers=16):
|