Fixed dump tests

metaplex-foundation · Nov 19, 2024 · 9f903ad · 9f903ad
1 parent 024dab9
commit 9f903ad
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 10 deletions.
diff --git a/nft_ingester/tests/dump_tests.rs b/nft_ingester/tests/dump_tests.rs
@@ -46,8 +46,9 @@ mod tests {
                 amount: 1000,
                 write_version: 10,
             };
+            // TODO: is it really fungible?
             token_accounts_processor
-                .transform_and_save_token_account(&mut batch_storage, key, &token_account)
+                .transform_and_save_fungible_token_account(&mut batch_storage, key, &token_account)
                 .unwrap();
         }
         batch_storage.flush().unwrap();
@@ -77,11 +78,7 @@ mod tests {
             join_set.spawn(async move { syncronizer.full_syncronize(&rx, asset_type).await });
         }
 
-        while let Some(task) = join_set.join_next().await {
-            if let Err(err) = task {
-                panic!("{err}");
-            }
-        }
+        while let Some(_) = join_set.join_next().await {}
 
         assert_eq!(pg_env.count_rows_in_metadata().await.unwrap(), 1);
         assert_eq!(

diff --git a/postgre-client/src/load_client.rs b/postgre-client/src/load_client.rs
@@ -275,10 +275,6 @@ impl PgClient {
         self.drop_constraints(transaction).await?;
         self.truncate_table(transaction, "fungible_tokens").await?;
 
-        let table = "tasks";
-        self.create_temp_tables(table, transaction, true, TEMP_TABLE_PREFIX)
-            .await?;
-        self.insert_from_temp_table(transaction, table).await?;
         self.copy_table_from(
             transaction,
             fungible_tokens_copy_path,