Skip to content

Commit d86ab7f

Browse files
committed
bumped version to 2.1.5
1 parent d2c1956 commit d86ab7f

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

.idea/distributed-scheduler.iml

+1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
name = "distributed-scheduler"
33
description = "A distributed cronjob library"
44
keywords = ["distributed", "scheduler", "cronjob", "consistent-hashing"]
5-
version = "2.1.4"
5+
version = "2.1.5"
66
edition = "2021"
77
repository = "https://github.com/AH-dark/distributed-scheduler.git"
88
homepage = "https://github.com/AH-dark/distributed-scheduler"

src/cron.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ where
115115
pub async fn add_async_job<F, Fut>(&self, job_name: &str, schedule: Schedule, run: F) -> Result<(), Error>
116116
where
117117
F: 'static + Sync + Send + Fn() -> Fut,
118-
Fut: Future<Output=Result<(), Box<dyn std::error::Error>>> + Send,
118+
Fut: Future<Output=()> + Send,
119119
{
120120
let run = Arc::new(run);
121121

@@ -135,7 +135,7 @@ where
135135
if np.check_job_available(&job_name)
136136
.await
137137
.is_ok_and(|is_this_node| is_this_node) {
138-
run().await.expect("Failed to run async job, runtime error");
138+
run().await;
139139
}
140140
});
141141
}

0 commit comments

Comments
 (0)