remove even failed tasks

ayrat555 · Sep 27, 2021 · b363e7d · b363e7d
1 parent a52baaa
commit b363e7d
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 28 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/lib.rs b/src/lib.rs
@@ -4,6 +4,7 @@ use crate::deliver::DeliverJob;
 use crate::sync::SyncJob;
 use fang::scheduler::Scheduler;
 use fang::Queue;
+use fang::RetentionMode;
 use fang::WorkerParams;
 use fang::WorkerPool;
 
@@ -67,5 +68,6 @@ fn start_workers(queue: &Queue, typ: String, number: u32) {
 
     let mut worker_params = WorkerParams::new();
     worker_params.set_task_type(typ);
+    worker_params.set_retention_mode(RetentionMode::RemoveAll);
     WorkerPool::new_with_params(number, worker_params).start();
 }