asonix/background-jobs
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Return error when failing to spawn enqueue

Browse source
This commit is contained in:
Aode (lion) 2021-11-17 11:43:14 -06:00
parent 1b673a13a0
commit f826a87a59
2 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
jobs-actix/Cargo.toml
View file

@ -1,7 +1,7 @@
[package]
name = "background-jobs-actix"
description = "in-process jobs processor based on Actix"
version = "0.9.4"
version = "0.9.5"
license-file = "../LICENSE"
authors = ["asonix <asonix@asonix.dog>"]
repository = "https://git.asonix.dog/Aardwolf/background-jobs"

10
jobs-actix/src/lib.rs
View file

@ -271,11 +271,14 @@ impl QueueHandle {
{
let job = new_job(job)?;
let server = self.inner.clone();
self.arbiter.spawn(async move {
let success = self.arbiter.spawn(async move {
if let Err(e) = server.new_job(job).await {
error!("Error creating job, {}", e);
}
});
if !success {
return Err(anyhow::anyhow!("Failed to queue job"));
}
Ok(())
}
@ -289,11 +292,14 @@ impl QueueHandle {
{
let job = new_scheduled_job(job, after)?;
let server = self.inner.clone();
self.arbiter.spawn(async move {
let success = self.arbiter.spawn(async move {
if let Err(e) = server.new_job(job).await {
error!("Error creating job, {}", e);
}
});
if !success {
return Err(anyhow::anyhow!("Failed to schedule job"));
}
Ok(())
}