fix(interactive): fix hqps ci (#4567)

liulx20 · web-flow · commit 986fd0828661 · 2025-03-12T12:49:22.000+08:00
Fixes
diff --git a/flex/engines/graph_db/database/graph_db.cc b/flex/engines/graph_db/database/graph_db.cc
@@ -479,15 +479,17 @@ void GraphDB::openWalAndCreateContexts(const GraphDBConfig& config,
   }
   VLOG(1) << "Using wal uri: " << wal_uri;
 
-  auto wal_parser = WalParserFactory::CreateWalParser(wal_uri);
-  ingestWals(*wal_parser, data_dir, thread_num_);
   for (int i = 0; i < thread_num_; ++i) {
     new (&contexts_[i])
         SessionLocalContext(*this, data_dir, i, allocator_strategy,
                             WalWriterFactory::CreateWalWriter(wal_uri));
-    contexts_[i].logger->open(wal_uri, i);
   }
+  auto wal_parser = WalParserFactory::CreateWalParser(wal_uri);
+  ingestWals(*wal_parser, data_dir, thread_num_);
 
+  for (int i = 0; i < thread_num_; ++i) {
+    contexts_[i].logger->open(wal_uri, i);
+  }
   initApps(graph_.schema().GetPlugins());
   VLOG(1) << "Successfully restore load plugins";
 }

Original file line number	Diff line number	Diff line change
`@@ -479,15 +479,17 @@ void GraphDB::openWalAndCreateContexts(const GraphDBConfig& config,`
`479`	`479`	`}`
`480`	`480`	`VLOG(1) << "Using wal uri: " << wal_uri;`
`481`	`481`
`482`		`- auto wal_parser = WalParserFactory::CreateWalParser(wal_uri);`
`483`		`- ingestWals(*wal_parser, data_dir, thread_num_);`
`484`	`482`	`for (int i = 0; i < thread_num_; ++i) {`
`485`	`483`	`new (&contexts_[i])`
`486`	`484`	`SessionLocalContext(*this, data_dir, i, allocator_strategy,`
`487`	`485`	`WalWriterFactory::CreateWalWriter(wal_uri));`
`488`		`- contexts_[i].logger->open(wal_uri, i);`
`489`	`486`	`}`
	`487`	`+ auto wal_parser = WalParserFactory::CreateWalParser(wal_uri);`
	`488`	`+ ingestWals(*wal_parser, data_dir, thread_num_);`
`490`	`489`
	`490`	`+ for (int i = 0; i < thread_num_; ++i) {`
	`491`	`+ contexts_[i].logger->open(wal_uri, i);`
	`492`	`+ }`
`491`	`493`	`initApps(graph_.schema().GetPlugins());`
`492`	`494`	`VLOG(1) << "Successfully restore load plugins";`
`493`	`495`	`}`