clean up from testing

Signed-off-by: Jesse Nelson <jesse@swirldslabs.com>
hashgraph · Apr 25, 2024 · 3af0b5e · 3af0b5e
1 parent b10f022
commit 3af0b5e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/hedera-mirror-importer/src/main/resources/db/scripts/v2/migration.config b/hedera-mirror-importer/src/main/resources/db/scripts/v2/migration.config
@@ -3,7 +3,7 @@ ASYNC_TABLE_SPLITS=
 CONCURRENCY=
 CONCURRENT_COPIES_PER_TABLE=
 CREATE_IDEXES_BEFORE_MIGRATION=
-EXCLUDED_TABLES=("'entity_state_start'","'entity_transaction'","'flyway_schema_history'","'transaction_hash'","'topic_message'")
+EXCLUDED_TABLES=("'entity_state_start'","'entity_transaction'","'flyway_schema_history'","'transaction_hash'")
 FLYWAY_URL=https://repo1.maven.org/maven2/org/flywaydb/flyway-commandline/9.22.3/flyway-commandline-9.22.3-linux-x64.tar.gz
 MAX_TIMESTAMP=
 SOURCE_DB_HOST=

diff --git a/hedera-mirror-importer/src/main/resources/db/scripts/v2/migration.sh b/hedera-mirror-importer/src/main/resources/db/scripts/v2/migration.sh
@@ -144,7 +144,7 @@ migrateTableBinary() {
   fi
 
   local where
-  if [[ "${table}" != "topic_message" && "${columns}" =~ $TS_COLUMN_REGEX ]]; then
+  if [[ "${columns}" =~ $TS_COLUMN_REGEX ]]; then
     where="where consensus_timestamp \<= ${MAX_TIMESTAMP}"
   # handle address book.
   elif [[ "${columns}" =~ \<consensus_timestamp_start\> ]]; then
@@ -202,9 +202,10 @@ migrateTableAsyncBinary() {
     else
       upperOperator="<"
     fi
+
     local where
     if [[ -z "${cursor_lower_bound}" ]]; then
-      where="where consensus_timestamp \<= ${cursor_upper_bound}"
+      where="where consensus_timestamp \\${upperOperator} ${cursor_upper_bound}"
     else
       where="where consensus_timestamp \\${upperOperator} ${cursor_upper_bound} and consensus_timestamp \\${lowerOperator} ${cursor_lower_bound}"
     fi
@@ -353,7 +354,6 @@ ASYNC_TABLES=$(echo "${ASYNC_TABLES//[\']/}" | tr "," "\n")
 
 declare tablesArray
 IFS=" " readarray -t tablesArray <<< "${TABLES}"
-tablesArray+=("topic_message")
 tablesArray+=("${ASYNC_TABLES[@]}")
 
 COUNT="${#tablesArray[@]}"