actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2025-06-29 10:14:58 +02:00
Code Issues Releases Wiki Activity

chore: update the apalis example to the latest version

Browse Source
This commit is contained in:
geofmureithi
2024-12-06 03:29:32 +03:00
parent 3bf5a5a372
commit d54a38ce73
3 changed files with 184 additions and 134 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
background-jobs/src/persistent_jobs.rs
View File

@ -34,15 +34,13 @@ pub(crate) async fn start_processing_email_queue() -> eyre::Result<RedisStorage<
let storage = RedisStorage::new_with_config(conn, config);
// create unmonitored workers for handling emails
let workers = WorkerBuilder::new("job-handler")
let worker = WorkerBuilder::new("job-handler")
.concurrency(2)
.backend(storage.clone())
.build_fn(process_email_job)
.with_executor_instances(2, TokioExecutor);
.build_fn(process_email_job);
for worker in workers {
#[allow(clippy::let_underscore_future)]
let _ = tokio::spawn(worker.run());
}
#[allow(clippy::let_underscore_future)]
let _ = tokio::spawn(worker.run());
Ok(storage)
}