if ($download_type eq 'full') {
    my $count = 0;
    my $session = OpenSRF::AppSession->create('open-ils.storage');
    my $request = $session->request('open-ils.storage.direct.biblio.record_entry.search_where', { "source" => $source->id, 'deleted' => 0 });
    my $response;
    until ($request->complete) {
        $response = $request->recv("timeout" => 10);
        my $bib = $response->content;
        my $r = OpenSRF::AppSession->create('open-ils.cat')->request('open-ils.cat.biblio.record_entry.delete', $authtoken, $bib->id)->gather(1);
        print(++$count . "\n");
    }
}