From e96f717f75769b9af637f8e4ec87505d57f2b201 Mon Sep 17 00:00:00 2001
From: zhjc1124 <zhjc1124@gmail.com>
Date: Mon, 26 Aug 2024 08:18:08 +0000
Subject: [PATCH] resume group_id when group guard destruct

---
 deps/oblib/src/lib/worker.h | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/deps/oblib/src/lib/worker.h b/deps/oblib/src/lib/worker.h
index 600f7592f1..730bc86001 100644
--- a/deps/oblib/src/lib/worker.h
+++ b/deps/oblib/src/lib/worker.h
@@ -220,7 +220,7 @@ public:
   ~ConsumerGroupIdGuard()
   {
     if (group_changed_) {
-      // SET_GROUP_ID(thread_group_id_);
+      SET_GROUP_ID(thread_group_id_);
     }
   }
   int get_ret()
@@ -241,7 +241,7 @@ public:
   ConsumerGroupFuncGuard(uint8_t func_type)
     : thread_group_id_(GET_GROUP_ID()), thread_func_type_(GET_FUNC_TYPE()), group_changed_(false), ret_(OB_SUCCESS)
   {
-    // THIS_WORKER.set_func_type_(func_type);
+    THIS_WORKER.set_func_type_(func_type);
     uint64_t group_id = 0;
     ret_ = CONVERT_FUNCTION_TYPE_TO_GROUP_ID(func_type, group_id);
     if (OB_SUCCESS == ret_ && is_user_group(group_id) && group_id != thread_group_id_) {
@@ -252,8 +252,8 @@ public:
   ~ConsumerGroupFuncGuard()
   {
     if (group_changed_) {
-      // SET_GROUP_ID(thread_group_id_);
-      // THIS_WORKER.set_func_type_(thread_func_type_);
+      SET_GROUP_ID(thread_group_id_);
+      THIS_WORKER.set_func_type_(thread_func_type_);
     }
   }
   int get_ret()