diff --git a/nft_ingester/tests/dump_tests.rs b/nft_ingester/tests/dump_tests.rs
index 84d59ad9..8849eb13 100644
--- a/nft_ingester/tests/dump_tests.rs
+++ b/nft_ingester/tests/dump_tests.rs
@@ -18,7 +18,6 @@ mod tests {
     use solana_program::pubkey::Pubkey;
     use tempfile::TempDir;
     use testcontainers::clients::Cli;
-    use tokio::task::JoinSet;
 
     #[tokio::test(flavor = "multi_thread", worker_threads = 10)]
     #[tracing_test::traced_test]
@@ -46,8 +45,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();
@@ -70,17 +70,8 @@ mod tests {
             1,
             false,
         ));
-        let mut join_set = JoinSet::new();
         for asset_type in ASSET_TYPES {
-            let syncronizer = syncronizer.clone();
-            let rx = rx.resubscribe();
-            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}");
-            }
+            syncronizer.full_syncronize(&rx, asset_type).await.unwrap();
         }
 
         assert_eq!(pg_env.count_rows_in_metadata().await.unwrap(), 1);
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,