More stuff

Author: DilumAluthge

test/error_path_manager_timeout.jl

@@ -1,3 +1,6 @@
+function unwrap_task_failed_ex(outer_ex::TaskFailedException)
+end
+
 mktempdir() do tmpdir
   fake_bindir = joinpath(tmpdir, "bin")
   fake_srun = joinpath(tmpdir, "bin", "srun")
@@ -33,9 +36,24 @@ mktempdir() do tmpdir
   @info "with old PATH" Sys.which("srun")
   withenv(new_env...) do
     @info "with new PATH" Sys.which("srun")
-    # expected_ex = ErrorException("launch_timeout exceeded")
-    expected_ex = ErrorException("Hello world!")
-    mgr = SlurmClusterManager.SlurmManager(; launch_timeout = 2.0) # 2.0 seconds
-    @test_throws expected_ex Distributed.addprocs(mgr)
+    expected_outer_ex_T = TaskFailedException
+    expected_inner_ex_T = ErrorException
+    expected_inner_ex_INSTANCE = ErrorException("launch_timeout exceeded")
+    mgr = SlurmClusterManager.SlurmManager(; launch_timeout = 2.0)
+    observed_outer_ex = @test_throws expected_ex Distributed.addprocs(mgr)
+    @info "" observed_outer_ex # TODO: Delete this line
+    @show dump(observed_outer_ex) # TODO: Delete this line
+    @test observed_outer_ex isa expected_outer_ex_T
+    if Base.VERSION >= v"1.1"
+      observed_inner_ex = unwrap_task_failed_ex(observed_outer_ex)
+      @info "" observed_inner_ex # TODO: Delete this line
+      @show dump(observed_inner_ex) # TODO: Delete this line
+      @test observed_inner_ex isa expected_inner_ex_T
+      @test observed_inner_ex == expected_inner_ex_INSTANCE
+    else
+      @warn "Skipping some tests on Julia 1.0.x" Base.VERSION
+      @test_skip false
+    end
+    @show observed_ex.task
   end
 end