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

Stress test cleanup

Browse source
This commit is contained in:
imbolc 2021-09-18 10:21:40 +03:00
parent 4529494e98
commit f13a86441f
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
sqlxmq_stress/src/main.rs
View file

@ -77,6 +77,12 @@ async fn main() -> Result<(), Box<dyn Error>> {
let pool = Pool::connect(&env::var("DATABASE_URL")?).await?;
// Remove possible artifacts of previous canceled (ctrl+c) runs
sqlx::query!("delete from mq_payloads")
.execute(&pool)
.await?;
sqlx::query!("delete from mq_msgs").execute(&pool).await?;
let registry = JobRegistry::new(&[example_job]);
let _runner = registry