diff --git a/nft_ingester/src/tasks/common/mod.rs b/nft_ingester/src/tasks/common/mod.rs index 19f1a12e9..9e3a30839 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.lteq(download_metadata.seq)) .add(asset_data::Column::DownloadMetadataSeq.is_null()), ); }