async fn produce_nar_inner<BE>(
blob_uploader: &mut ConcurrentBlobUploader<BE>,
node: Node<'_, '_>,
path: PathBuf,
tx: Sender<Result<IngestionEntry, Error>>,
) -> Result<IngestionEntry, Error>where
BE: BlobEngine + Clone + 'static,