mirrors/sqlxmq
1
0
Fork 0
mirror of https://github.com/Diggsey/sqlxmq.git synced 2024-05-31 23:48:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Increace waiter step

Browse source
This commit is contained in:
imbolc 2022-07-17 00:45:29 +03:00
parent 1b01f1f069
commit 3e8c7b1bc7
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/runner.rs
View file

@ -336,7 +336,7 @@ impl JobRunnerHandle {
/// Wait for the jobs to finish, but not more than `timeout`
pub async fn wait_jobs_finish(&self, timeout: Duration) {
let start = Instant::now();
let step = Duration::from_millis(1);
let step = Duration::from_millis(10);
while self.num_running_jobs() > 0 && start.elapsed() < timeout {
tokio::time::sleep(step).await;
}