@@ -45,7 +45,7 @@ async fn job_is_locked(id: i64, conn: &mut AsyncPgConnection) -> bool {
4545 . is_none ( )
4646}
4747
48- #[ tokio:: test( flavor = "multi_thread" ) ]
48+ #[ tokio:: test]
4949async fn jobs_are_locked_when_fetched ( ) {
5050 #[ derive( Clone ) ]
5151 struct TestContext {
@@ -96,7 +96,7 @@ async fn jobs_are_locked_when_fetched() {
9696 assert ! ( !job_exists( job_id, & mut conn) . await ) ;
9797}
9898
99- #[ tokio:: test( flavor = "multi_thread" ) ]
99+ #[ tokio:: test]
100100async fn jobs_are_deleted_when_successfully_run ( ) {
101101 #[ derive( Serialize , Deserialize ) ]
102102 struct TestJob ;
@@ -135,7 +135,7 @@ async fn jobs_are_deleted_when_successfully_run() {
135135 assert_eq ! ( remaining_jobs( & mut conn) . await , 0 ) ;
136136}
137137
138- #[ tokio:: test( flavor = "multi_thread" ) ]
138+ #[ tokio:: test]
139139async fn failed_jobs_do_not_release_lock_before_updating_retry_time ( ) {
140140 #[ derive( Clone ) ]
141141 struct TestContext {
@@ -196,7 +196,7 @@ async fn failed_jobs_do_not_release_lock_before_updating_retry_time() {
196196 runner. wait_for_shutdown ( ) . await ;
197197}
198198
199- #[ tokio:: test( flavor = "multi_thread" ) ]
199+ #[ tokio:: test]
200200async fn panicking_in_jobs_updates_retry_counter ( ) {
201201 #[ derive( Serialize , Deserialize ) ]
202202 struct TestJob ;
@@ -232,7 +232,7 @@ async fn panicking_in_jobs_updates_retry_counter() {
232232 assert_eq ! ( tries, 1 ) ;
233233}
234234
235- #[ tokio:: test( flavor = "multi_thread" ) ]
235+ #[ tokio:: test]
236236async fn jobs_can_be_deduplicated ( ) {
237237 #[ derive( Clone ) ]
238238 struct TestContext {
0 commit comments