fix: Remove deletion of old logs and metadata tables (#679)

All tables have been migrated to using the new tables. This code hook for deleting old tables is no longer necessary.
near · Apr 20, 2024 · 1a877eb · 1a877eb
1 parent c2f5f0d
commit 1a877eb
Showing 1 changed file with 0 additions and 28 deletions.
diff --git a/runner/src/provisioner/provisioner.ts b/runner/src/provisioner/provisioner.ts
@@ -255,40 +255,12 @@ export default class Provisioner {
     if (this.#hasLogsMetadataBeenProvisioned[indexerConfig.accountId]?.[indexerConfig.functionName]) {
       return;
     }
-    const oldLogsTable = '__logs';
-    const oldMetadataTable = '__metadata';
     const logsTable = 'sys_logs';
     const metadataTable = 'sys_metadata';
 
     await wrapError(
       async () => {
         const tableNames = await this.getTableNames(indexerConfig.schemaName(), indexerConfig.databaseName());
-        if (tableNames.includes(oldLogsTable)) {
-          try {
-            await this.hasuraClient.untrackTables(indexerConfig.databaseName(), indexerConfig.schemaName(), [oldLogsTable], true);
-          } catch (err) {
-            const error = err as Error;
-            if (!error.message.includes('already untracked')) {
-              console.error(error.message);
-            }
-          }
-        }
-        if (tableNames.includes(oldMetadataTable)) {
-          try {
-            await this.hasuraClient.untrackTables(indexerConfig.databaseName(), indexerConfig.schemaName(), [oldMetadataTable], true);
-          } catch (err) {
-            const error = err as Error;
-            if (!error.message.includes('already untracked')) {
-              console.error(error.message);
-            }
-          }
-        }
-        if (tableNames.includes(oldLogsTable)) {
-          await this.hasuraClient.executeSqlOnSchema(indexerConfig.databaseName(), indexerConfig.schemaName(), `DROP TABLE IF EXISTS ${oldLogsTable} CASCADE;`);
-        }
-        if (tableNames.includes(oldMetadataTable)) {
-          await this.hasuraClient.executeSqlOnSchema(indexerConfig.databaseName(), indexerConfig.schemaName(), `DROP TABLE IF EXISTS ${oldMetadataTable};`);
-        }
 
         if (!tableNames.includes(logsTable)) {
           await this.setupPartitionedLogsTable(indexerConfig.userName(), indexerConfig.databaseName(), indexerConfig.schemaName());