diff --git a/nft_ingester/src/program_transformers/token_metadata/v1_asset.rs b/nft_ingester/src/program_transformers/token_metadata/v1_asset.rs index 4388e0e2..21ff6624 100644 --- a/nft_ingester/src/program_transformers/token_metadata/v1_asset.rs +++ b/nft_ingester/src/program_transformers/token_metadata/v1_asset.rs @@ -340,9 +340,9 @@ pub async fn save_v1_asset( ) .build(DbBackend::Postgres); query.sql = format!( - "{} WHERE excluded.slot_updated > asset_grouping.slot_updated AND excluded.seq >= asset_grouping.seq", - query.sql - ); + "{} WHERE excluded.slot_updated > asset_grouping.slot_updated", + query.sql + ); txn.execute(query) .await .map_err(|db_err| IngesterError::AssetIndexError(db_err.to_string()))?;