diff options
Diffstat (limited to 'kittybox-rs/src/webmentions/queue.rs')
-rw-r--r-- | kittybox-rs/src/webmentions/queue.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/kittybox-rs/src/webmentions/queue.rs b/kittybox-rs/src/webmentions/queue.rs index dc7d8f9..b811e71 100644 --- a/kittybox-rs/src/webmentions/queue.rs +++ b/kittybox-rs/src/webmentions/queue.rs @@ -205,9 +205,10 @@ impl JobQueue<Webmention> for PostgresJobQueue<Webmention> { mod tests { use std::sync::Arc; - use super::{Webmention, PostgresJobQueue, Job, JobQueue}; + use super::{Webmention, PostgresJobQueue, Job, JobQueue, MIGRATOR}; use futures_util::StreamExt; - #[sqlx::test] + + #[sqlx::test(migrator = "MIGRATOR")] #[tracing_test::traced_test] async fn test_webmention_queue(pool: sqlx::PgPool) -> Result<(), sqlx::Error> { let test_webmention = Webmention { @@ -248,7 +249,7 @@ mod tests { } } - #[sqlx::test] + #[sqlx::test(migrator = "MIGRATOR")] #[tracing_test::traced_test] async fn test_no_hangups_in_queue(pool: sqlx::PgPool) -> Result<(), sqlx::Error> { let test_webmention = Webmention { |