fixup! debug

Author: JamesWrigley

test/topology.jl

@@ -3,11 +3,11 @@
 using Random
 
 @testset "Topology" begin
-    pids = addprocs_with_testenv(4; topology="master_worker")
+    # pids = addprocs_with_testenv(4; topology="master_worker")
 
-    let p1 = pids[1], p2 = pids[2]
-        @test_throws RemoteException remotecall_fetch(()->remotecall_fetch(myid, p2), p1)
-    end
+    # let p1 = pids[1], p2 = pids[2]
+    #     @test_throws RemoteException remotecall_fetch(()->remotecall_fetch(myid, p2), p1)
+    # end
 
     function test_worker_counts()
         # check if the nprocs/nworkers/workers are the same on the remaining workers
@@ -32,7 +32,7 @@ using Random
         end
     end
 
-    remove_workers_and_test()
+    # remove_workers_and_test()
 
     # connect even pids to other even pids, odd to odd.
     mutable struct TopoTestManager <: ClusterManager
@@ -95,7 +95,7 @@ using Random
     # end
 
     @info "finished TopoTestManager"
-    remove_workers_and_test()
+    # remove_workers_and_test()
 
     # test `lazy` connection setup
     function def_count_conn()
@@ -130,18 +130,20 @@ using Random
         @test num_conns == expected_num_conns
     end
 
-    for (i, (from,to)) in enumerate(combinations)
-        remotecall_wait(topid->remotecall_fetch(myid, topid), from, to)
-        expected_num_conns += 2    # one connection endpoint on both from and to
-        let num_conns = sum(asyncmap(p->remotecall_fetch(count_connected_workers,p), workers()))
-            @test num_conns == expected_num_conns
-        end
-    end
+    # for (i, (from,to)) in enumerate(combinations)
+    #     remotecall_wait(topid->remotecall_fetch(myid, topid), from, to)
+    #     expected_num_conns += 2    # one connection endpoint on both from and to
+    #     let num_conns = sum(asyncmap(p->remotecall_fetch(count_connected_workers,p), workers()))
+    #         @test num_conns == expected_num_conns
+    #     end
+    # end
 
     @info "finished master-worker"
     # With lazy=false, all connections ought to be setup during `addprocs`
     @show workers()
     nprocs() > 1 && rmprocs(workers())
+    return
+
     addprocs_with_testenv(8; lazy=false)
     def_count_conn()
     @test sum(asyncmap(p->remotecall_fetch(count_connected_workers,p), workers())) == 64