diff --git a/flex/engines/graph_db/database/wal.h b/flex/engines/graph_db/database/wal.h
index 4f86c91f4f3d..55a86e53d83f 100644
--- a/flex/engines/graph_db/database/wal.h
+++ b/flex/engines/graph_db/database/wal.h
@@ -26,8 +26,6 @@
 #include <string>
 #include <thread>
 
-#include "flex/utils/result.h"
-
 #ifdef BUILD_KAFKA_WAL_WRITER
 #include "cppkafka/cppkafka.h"
 #endif
diff --git a/flex/engines/http_server/handler/graph_db_http_handler.cc b/flex/engines/http_server/handler/graph_db_http_handler.cc
index a245796dc7f2..262053f436ec 100644
--- a/flex/engines/http_server/handler/graph_db_http_handler.cc
+++ b/flex/engines/http_server/handler/graph_db_http_handler.cc
@@ -426,16 +426,6 @@ class stored_proc_handler : public StoppableHandler {
   }
 
  private:
-  std::pair<int, seastar::sstring> get_executor_id_from_wal_payload(
-      const seastar::sstring& payload) {
-    if (payload.size() < 4) {
-      LOG(ERROR) << "Invalid payload size: " << payload.size();
-      return std::make_pair(-1, payload);
-    }
-    auto executor_id = *reinterpret_cast<const int*>(payload.data());
-    return std::make_pair(executor_id, payload.substr(4));
-  }
-
   query_dispatcher dispatcher_;
 #ifdef HAVE_OPENTELEMETRY_CPP
   opentelemetry::nostd::unique_ptr<opentelemetry::metrics::Counter<uint64_t>>