Don't stop raking due to errors from processing a domain
This commit is contained in:
parent
5719d0b402
commit
791fa8c4ee
|
@ -8,7 +8,7 @@ use crate::storage::{RakerStore, RandomActiveDomainAcquisition};
|
||||||
use anyhow::{anyhow, ensure, Context};
|
use anyhow::{anyhow, ensure, Context};
|
||||||
use chrono::Utc;
|
use chrono::Utc;
|
||||||
use cylon::Cylon;
|
use cylon::Cylon;
|
||||||
use log::warn;
|
use log::{error, warn};
|
||||||
use lru::LruCache;
|
use lru::LruCache;
|
||||||
use quickpeep_structs::rake_entries::{
|
use quickpeep_structs::rake_entries::{
|
||||||
IconEntry, RakedPageEntry, RakedReference, RakedReferrerEntry, ReferenceKind,
|
IconEntry, RakedPageEntry, RakedReference, RakedReferrerEntry, ReferenceKind,
|
||||||
|
@ -93,7 +93,9 @@ impl TaskContext {
|
||||||
domain,
|
domain,
|
||||||
record: _active_record,
|
record: _active_record,
|
||||||
} => {
|
} => {
|
||||||
self.process_domain(domain.clone()).await?;
|
if let Err(err) = self.process_domain(domain.clone()).await {
|
||||||
|
error!("Encountered error processing {:?}: {:?}", domain, err);
|
||||||
|
}
|
||||||
ensure!(
|
ensure!(
|
||||||
self.busy_domains
|
self.busy_domains
|
||||||
.lock()
|
.lock()
|
||||||
|
|
Loading…
Reference in New Issue