format

Author: xy720

be/test/agent/task_worker_pool_test.cpp

@@ -141,21 +141,21 @@ TEST(TaskWorkerPoolTest, ReportTabletCallbackWithDebugPoint) {
     ClusterInfo cluster_info;
     cluster_info.master_fe_addr.__set_port(9030);
 
-    Defer defer {[] {
-        ExecEnv::GetInstance()->set_storage_engine(nullptr);
-    }};
+    Defer defer {[] { ExecEnv::GetInstance()->set_storage_engine(nullptr); }};
 
     {
         // debug point is enabled
         DebugPoints::instance()->add("WorkPoolReportTablet.report_tablet_callback.skip");
-        EXPECT_TRUE(DebugPoints::instance()->is_enable("WorkPoolReportTablet.report_tablet_callback.skip"));
+        EXPECT_TRUE(DebugPoints::instance()->is_enable(
+                "WorkPoolReportTablet.report_tablet_callback.skip"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_local(), &cluster_info);
     }
 
     {
         // debug point is removed
         DebugPoints::instance()->remove("WorkPoolReportTablet.report_tablet_callback.skip");
-        EXPECT_FALSE(DebugPoints::instance()->is_enable("WorkPoolReportTablet.report_tablet_callback.skip"));
+        EXPECT_FALSE(DebugPoints::instance()->is_enable(
+                "WorkPoolReportTablet.report_tablet_callback.skip"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_local(), &cluster_info);
     }
 

be/test/cloud/cloud_task_worker_pool_test.cpp

@@ -15,12 +15,11 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "agent/task_worker_pool.h"
-
 #include <gtest/gtest.h>
 
-#include "olap/options.h"
+#include "agent/task_worker_pool.h"
 #include "cloud/cloud_storage_engine.h"
+#include "olap/options.h"
 #include "runtime/cluster_info.h"
 
 namespace doris {
@@ -30,25 +29,27 @@ TEST(CloudTaskWorkerPoolTest, ReportTabletCallbackWithDebugPoint) {
     config::enable_debug_points = true;
 
     ExecEnv::GetInstance()->set_storage_engine(std::make_unique<CloudStorageEngine>(EngineOptions {}));
+    ExecEnv::GetInstance()->set_storage_engine(
+            std::make_unique<CloudStorageEngine>(EngineOptions {}));
 
     ClusterInfo cluster_info;
     cluster_info.master_fe_addr.__set_port(9030);
 
-    Defer defer {[] {
-        ExecEnv::GetInstance()->set_storage_engine(nullptr);
-    }};
+    Defer defer {[] { ExecEnv::GetInstance()->set_storage_engine(nullptr); }};
 
     {
         // debug point is enabled
         DebugPoints::instance()->add("WorkPoolCloudReportTablet.report_tablet_callback.skip");
-        EXPECT_TRUE(DebugPoints::instance()->is_enable("WorkPoolCloudReportTablet.report_tablet_callback.skip"));
+        EXPECT_TRUE(DebugPoints::instance()->is_enable(
+                "WorkPoolCloudReportTablet.report_tablet_callback.skip"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_cloud(), &cluster_info);
     }
 
     {
         // debug point is removed
         DebugPoints::instance()->remove("WorkPoolCloudReportTablet.report_tablet_callback.skip");
-        EXPECT_FALSE(DebugPoints::instance()->is_enable("WorkPoolCloudReportTablet.report_tablet_callback.skip"));
+        EXPECT_FALSE(DebugPoints::instance()->is_enable(
+                "WorkPoolCloudReportTablet.report_tablet_callback.skip"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_cloud(), &cluster_info);
     }