diff --git a/nft_ingester/src/tasks/common/mod.rs b/nft_ingester/src/tasks/common/mod.rs index 19f1a12e9..3b533c2f7 100644 --- a/nft_ingester/src/tasks/common/mod.rs +++ b/nft_ingester/src/tasks/common/mod.rs @@ -123,7 +123,7 @@ impl BgTask for DownloadMetadataTask { if download_metadata.seq != 0 { query = query.filter( Condition::any() - .add(asset_data::Column::DownloadMetadataSeq.lt(download_metadata.seq)) + .add(asset_data::Column::DownloadMetadataSeq.lte(download_metadata.seq)) .add(asset_data::Column::DownloadMetadataSeq.is_null()), ); }