Merge remote-tracking branch 'origin/main' into drop-pg16-support

Author: khustup2

cpp/deeplake_pg/extension_init.cpp

@@ -643,7 +643,6 @@ static void process_utility(PlannedStmt* pstmt,
                     }
                 }
 
-                // DROP SCHEMA propagation is handled by DDL WAL logging post-hook.
             }
         } else if (stmt->removeType == OBJECT_DATABASE) {
             const char* query = "SELECT nspname, relname "

cpp/deeplake_pg/pg_deeplake.cpp

@@ -265,8 +265,6 @@ void save_index_metadata(Oid oid)
     if (SPI_execute(buf.data, false, 0) != SPI_OK_INSERT) {
         ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to save metadata")));
     }
-
-    // Cross-instance propagation is driven by DDL WAL logging in ProcessUtility.
 }
 
 void load_index_metadata()

cpp/deeplake_pg/sync_worker.cpp

@@ -32,6 +32,10 @@ extern "C" {
 #include "table_storage.hpp"
 #include "utils.hpp"
 
+#include <async/promise.hpp>
+#include <deeplake_api/catalog_table.hpp>
+#include <icm/vector.hpp>
+
 #include <algorithm>
 #include <cstdio>
 #include <cstring>
@@ -550,7 +554,6 @@ PGDLLEXPORT void deeplake_sync_worker_main(Datum main_arg)
     std::unordered_map<std::string, int64_t> last_db_seqs;
     load_wal_checkpoints(last_db_seqs);
 
-
     while (!got_sigterm) {
         // Process pending interrupts (including ProcSignalBarrier from DROP DATABASE)
         CHECK_FOR_INTERRUPTS();

cpp/deeplake_pg/table_storage.cpp

@@ -240,8 +240,6 @@ void table_storage::save_table_metadata(const pg::table_data& table_data)
         }
         return true;
     });
-
-    // Stateless sync uses DDL WAL replay from __wal_table.
 }
 
 void table_storage::load_table_metadata()
@@ -855,7 +853,6 @@ void table_storage::drop_table(const std::string& table_name)
         auto& table_data = get_table_data(table_name);
         auto creds = session_credentials::get_credentials();
 
-        // Stateless propagation is handled by DDL WAL logging in ProcessUtility hook.
 
         try {
             table_data.commit(); // Ensure all changes are committed before deletion