diff --git a/nft_ingester/tests/dump_tests.rs b/nft_ingester/tests/dump_tests.rs index 84d59ad9..c7bce52b 100644 --- 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 index 039e2b2f..37a93e85 100644 --- 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,