Set sleep time shorter
This commit is contained in:
parent
4aee72baf4
commit
f7ee3845d3
|
|
@ -689,6 +689,7 @@ where
|
|||
}
|
||||
|
||||
let mut conn_result = sqlx::mysql::MySqlConnection::connect(DB_URL).await;
|
||||
|
||||
//retry connection until it will be done.
|
||||
while conn_result.is_err() {
|
||||
sleep(Duration::from_millis(200)).await;
|
||||
|
|
@ -699,7 +700,7 @@ where
|
|||
// let mut query_result: Vec<T> = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await?;
|
||||
let mut query_result = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await;
|
||||
let mut query_result_vec: Vec<T> = Vec::new();
|
||||
|
||||
|
||||
loop {
|
||||
match query_result {
|
||||
Ok(T) => {
|
||||
|
|
@ -707,12 +708,12 @@ where
|
|||
query_result_vec = T;
|
||||
break;
|
||||
} else {
|
||||
sleep(Duration::from_millis(200)).await;
|
||||
sleep(Duration::from_millis(50)).await;
|
||||
query_result = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await;
|
||||
}
|
||||
}
|
||||
Err(e) => {
|
||||
sleep(Duration::from_millis(200)).await;
|
||||
sleep(Duration::from_millis(50)).await;
|
||||
query_result = sqlx::query_as::<_, T>(&query).fetch_all(&mut conn).await;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user