From 88b1b0998497aab29bed2b721f21bb948efd9425 Mon Sep 17 00:00:00 2001 From: Anjor Kanekar Date: Thu, 20 Feb 2025 09:21:47 +0000 Subject: [PATCH] fix deal making (#232) --- dataprep-tools/filecoin/boost_create_deals.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dataprep-tools/filecoin/boost_create_deals.py b/dataprep-tools/filecoin/boost_create_deals.py index 4c3c284c..6a30a7e0 100644 --- a/dataprep-tools/filecoin/boost_create_deals.py +++ b/dataprep-tools/filecoin/boost_create_deals.py @@ -354,10 +354,10 @@ def create_deals_for_metadata(metadata_obj, epoch_str, deal_type_suffix=""): logger.info(f"Found {len(providers)} providers: {providers}") for provider in providers: + if file_item["commp_piece_cid"] not in replications: + replications[file_item["commp_piece_cid"]] = [] if not USE_CID_GRAVITY: - if file_item["commp_piece_cid"] not in replications: - replications[file_item["commp_piece_cid"]] = [] - elif provider in replications[file_item["commp_piece_cid"]]: + if provider in replications[file_item["commp_piece_cid"]]: logger.info(f"Skipping deal for {file_item['commp_piece_cid']} with {provider}, already has a deal.") continue elif len(replications[file_item["commp_piece_cid"]]) >= replication_factor: