allow reset simple parallel

block-hczhai · Sep 22, 2024 · ec1aa38 · ec1aa38
1 parent 9e8a81d
commit ec1aa38
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/core/parallel_rule.hpp b/src/core/parallel_rule.hpp
@@ -346,6 +346,8 @@ template <typename S> struct ParallelRule<S> {
             frame_<float>()->prefix_can_write = is_root();
         } else
             throw runtime_error("DataFrame not defined!");
+        if (comm->para_type & ParallelTypes::Simple)
+            comm->para_type = comm->para_type ^ ParallelTypes::Simple;
     }
     virtual ~ParallelRule() = default;
     ParallelTypes get_parallel_type() const {