From 2c79515e91d896d494f46911c8374f459dd04254 Mon Sep 17 00:00:00 2001 From: Jamie Mair Date: Fri, 15 Dec 2023 11:17:13 +0000 Subject: [PATCH] Removed heterogeneous from CI running --- test/runner.jl | 38 ++++++++++++++++++++------------------ 1 file changed, 20 insertions(+), 18 deletions(-) diff --git a/test/runner.jl b/test/runner.jl index c9f4ca5..fa556b1 100644 --- a/test/runner.jl +++ b/test/runner.jl @@ -81,23 +81,25 @@ end end @testset "Heterogeneous Running" begin - # Launch two processes with access to 2 threads - ps = addprocs(2; exeflags=["--threads=2"]) - database = open_db("runner test"; in_memory=true) - experiment = get_heterogeneous_experiment("heterogeneous distributed execution test", get_heterogeneous_config()) - - # Launch 2 threads per node - @execute experiment database HeterogeneousMode(2) false directory - - - trials = get_trials_by_name(database, experiment.name) - for pid in ps - max_threads = maximum([t.results[:num_threads] for t in trials if t.results[:distributed_id] == pid]) - max_threads = min(max_threads, length([true for t in trials if t.results[:distributed_id] == pid])) - thread_ids = [t.results[:thread_id] for t in trials if t.results[:distributed_id] == pid] - unique_threads = length(unique(thread_ids)) - @test unique_threads == max_threads + if get(ENV, "CI", "false") != "true" + # Launch two processes with access to 2 threads + ps = addprocs(2; exeflags=["--threads=2"]) + database = open_db("runner test"; in_memory=true) + experiment = get_heterogeneous_experiment("heterogeneous distributed execution test", get_heterogeneous_config()) + + # Launch 2 threads per node + @execute experiment database HeterogeneousMode(2) false directory + + + trials = get_trials_by_name(database, experiment.name) + for pid in ps + max_threads = maximum([t.results[:num_threads] for t in trials if t.results[:distributed_id] == pid]) + max_threads = min(max_threads, length([true for t in trials if t.results[:distributed_id] == pid])) + thread_ids = [t.results[:thread_id] for t in trials if t.results[:distributed_id] == pid] + unique_threads = length(unique(thread_ids)) + @test unique_threads == max_threads + end + # Cleanup + rmprocs(ps...) end - # Cleanup - rmprocs(ps...) end \ No newline at end of file