Print how many circuits we have

src/protocol/ipa_prf/prf_sharding/mod.rs

@@ -443,6 +443,7 @@ where
 
     let mut collected = rows_chunked_by_user.collect::<Vec<_>>().await;
     collected.sort_by(|a, b| std::cmp::Ord::cmp(&b.len(), &a.len()));
+    tracing::info!("Processing {} user circuits (expected {num_outputs})", collected.len());
 
     // Convert to a stream of async futures that represent the result of executing the per-user circuit
     let stream_of_per_user_circuits = pin!(stream_iter(collected).then(|rows_for_user| {

src/protocol/modulus_conversion/convert_shares.rs

@@ -354,12 +354,11 @@ where
     );
 
     let active = ctx.active_work();
-    let sz = binary_shares.size_hint().1.unwrap_or(0);
     let locally_converted = LocalBitConverter::new(ctx.role(), binary_shares, bit_range);
     let stream = unfold(
         (ctx, locally_converted, first_record),
         move |(ctx, mut locally_converted, record_id)| async move {
-            tracing::trace!("convert bits for {}/{record_id} out of {sz}", ctx.gate().as_ref());
+            tracing::trace!("convert bits for {}/{record_id} out of {}", ctx.gate().as_ref(), ctx.total_records());
             let Some((triple, residual)) = locally_converted.next().await else {
                 return None;
             };