diff --git a/analytical_engine/apps/property/wcc_property.h b/analytical_engine/apps/property/wcc_property.h index 09db60a64aec..7cdb7f975914 100644 --- a/analytical_engine/apps/property/wcc_property.h +++ b/analytical_engine/apps/property/wcc_property.h @@ -140,6 +140,7 @@ class WCCProperty : public PropertyAppBase> { } } + HandleMessageForceContinue(frag, ctx, messages); ctx.curr_modified.swap(ctx.next_modified); } @@ -205,6 +206,14 @@ class WCCProperty : public PropertyAppBase> { } } } + + HandleMessageForceContinue(frag, ctx, messages); + ctx.curr_modified.swap(ctx.next_modified); + } + + void HandleMessageForceContinue(const fragment_t& frag, context_t& ctx, + message_manager_t& messages) { + label_id_t v_label_num = frag.vertex_label_num(); for (label_id_t i = 0; i < v_label_num; ++i) { auto iv = frag.InnerVertices(i); bool ok = false; @@ -219,7 +228,6 @@ class WCCProperty : public PropertyAppBase> { break; } } - ctx.curr_modified.swap(ctx.next_modified); } };