diff --git a/mobile_verifier/src/boosting_oracles/data_sets.rs b/mobile_verifier/src/boosting_oracles/data_sets.rs index f5c6c14c3..80ab2b931 100644 --- a/mobile_verifier/src/boosting_oracles/data_sets.rs +++ b/mobile_verifier/src/boosting_oracles/data_sets.rs @@ -339,15 +339,17 @@ where _ = self.new_coverage_object_signal.recv() => { // If we see a new coverage object, we want to assign only those hexes // that don't have an assignment - let boosting_reports = set_oracle_boosting_assignments( - UnassignedHex::fetch_unassigned(&self.pool), - &self.data_sets, - &self.pool, - ) - .await?; - self.oracle_boosting_sink - .write_all(boosting_reports) + if self.data_sets.is_ready() { + let boosting_reports = set_oracle_boosting_assignments( + UnassignedHex::fetch_unassigned(&self.pool), + &self.data_sets, + &self.pool, + ) .await?; + self.oracle_boosting_sink + .write_all(boosting_reports) + .await?; + } }, _ = tokio::time::sleep(poll_duration.to_std()?) => { self.check_for_new_data_sets().await?;