diff --git a/experiments/post_processing/post_processing.jl b/experiments/post_processing/post_processing.jl index f70aabe43c34d7474afc522dd98013210eab5543..7eefa387067dc6ebfa88b596d5d20d9d1e0aabe2 100644 --- a/experiments/post_processing/post_processing.jl +++ b/experiments/post_processing/post_processing.jl @@ -1,3 +1,2 @@ include("meta_data.jl") -include("artifacts.jl") -include("results.jl") \ No newline at end of file +include("artifacts.jl") \ No newline at end of file diff --git a/experiments/post_processing/results.jl b/experiments/post_processing/results.jl deleted file mode 100644 index 3b44bcd2abb9f2c035adc267a1fc3bb31ca72af2..0000000000000000000000000000000000000000 --- a/experiments/post_processing/results.jl +++ /dev/null @@ -1,14 +0,0 @@ -""" - aggregate_results(outcome::ExperimentOutcome; measure::String="distance_from_targets") - -Function to quickly aggregate benchmarking results for a given measure. -""" -function aggregate_results(outcome::ExperimentOutcome; measure::String="distance_from_targets") - df = @chain outcome.bmk() begin - @group_by(generator, model) - @filter(variable == measure) - @summarize(val = mean(value), std = std(value)) - @ungroup - end - return df -end \ No newline at end of file diff --git a/experiments/utils.jl b/experiments/utils.jl index 27df74b55622bb86835a133813d40b957521bd5c..c1de7279522585064aacc84e4327d97e6d27c508 100644 --- a/experiments/utils.jl +++ b/experiments/utils.jl @@ -1,3 +1,11 @@ -is_multi_processed(exper::Experiment) = isa(exper.parallelizer, Base.get_extension(CounterfactualExplanations, :MPIExt).MPIParallelizer) +using CounterfactualExplanations.Parallelization: ThreadsParallelizer -is_multi_processed(parallelizer::AbstractParallelizer) = isa(parallelizer, Base.get_extension(CounterfactualExplanations, :MPIExt).MPIParallelizer) \ No newline at end of file +function is_multi_processed(parallelizer::Union{Nothing,AbstractParallelizer}) + if isnothing(parallelizer) || isa(parallelizer, ThreadsParallelizer) + return false + else + return isa(parallelizer, Base.get_extension(CounterfactualExplanations, :MPIExt).MPIParallelizer) + end +end + +is_multi_processed(exper::Experiment) = is_multi_processed(exper.parallelizer) \ No newline at end of file