@@ -181,7 +181,7 @@ pub trait Connection: Send + Sync {
181
181
async fn purge_artifact ( & self , aid : & ArtifactId ) ;
182
182
183
183
/// Add an item to the `benchmark_requests`, if the `benchmark_request`
184
- /// exists it will be ignored
184
+ /// exists an Error will be returned
185
185
async fn insert_benchmark_request (
186
186
& self ,
187
187
benchmark_request : & BenchmarkRequest ,
@@ -439,18 +439,15 @@ mod tests {
439
439
) ;
440
440
441
441
let db = db. connection ( ) . await ;
442
- assert ! ( db
443
- . insert_benchmark_request( & master_benchmark_request)
442
+ db. insert_benchmark_request ( & master_benchmark_request)
444
443
. await
445
- . is_ok( ) ) ;
446
- assert ! ( db
447
- . insert_benchmark_request( & try_benchmark_request)
444
+ . unwrap ( ) ;
445
+ db. insert_benchmark_request ( & try_benchmark_request)
448
446
. await
449
- . is_ok( ) ) ;
450
- assert ! ( db
451
- . insert_benchmark_request( & release_benchmark_request)
447
+ . unwrap ( ) ;
448
+ db. insert_benchmark_request ( & release_benchmark_request)
452
449
. await
453
- . is_ok ( ) ) ;
450
+ . unwrap ( ) ;
454
451
// duplicate insert
455
452
assert ! ( db
456
453
. insert_benchmark_request( & master_benchmark_request)
@@ -498,18 +495,15 @@ mod tests {
498
495
) ;
499
496
500
497
let db = db. connection ( ) . await ;
501
- assert ! ( db
502
- . insert_benchmark_request( & master_benchmark_request)
498
+ db. insert_benchmark_request ( & master_benchmark_request)
503
499
. await
504
- . is_ok( ) ) ;
505
- assert ! ( db
506
- . insert_benchmark_request( & try_benchmark_request)
500
+ . unwrap ( ) ;
501
+ db. insert_benchmark_request ( & try_benchmark_request)
507
502
. await
508
- . is_ok( ) ) ;
509
- assert ! ( db
510
- . insert_benchmark_request( & release_benchmark_request)
503
+ . unwrap ( ) ;
504
+ db. insert_benchmark_request ( & release_benchmark_request)
511
505
. await
512
- . is_ok ( ) ) ;
506
+ . unwrap ( ) ;
513
507
514
508
let requests = db
515
509
. get_benchmark_requests_by_status ( & [ BenchmarkRequestStatus :: ArtifactsReady ] )
@@ -543,10 +537,9 @@ mod tests {
543
537
) ;
544
538
545
539
let mut db = db. connection ( ) . await ;
546
- assert ! ( db
547
- . insert_benchmark_request( & master_benchmark_request)
540
+ db. insert_benchmark_request ( & master_benchmark_request)
548
541
. await
549
- . is_ok ( ) ) ;
542
+ . unwrap ( ) ;
550
543
551
544
db. update_benchmark_request_status (
552
545
& master_benchmark_request,
@@ -586,10 +579,9 @@ mod tests {
586
579
"cranelift" ,
587
580
"" ,
588
581
) ;
589
- assert ! ( db
590
- . insert_benchmark_request( & try_benchmark_request)
582
+ db. insert_benchmark_request ( & try_benchmark_request)
591
583
. await
592
- . is_ok ( ) ) ;
584
+ . unwrap ( ) ;
593
585
db. attach_shas_to_try_benchmark_request ( pr, "foo" , "bar" )
594
586
. await
595
587
. unwrap ( ) ;
@@ -625,7 +617,7 @@ mod tests {
625
617
"cranelift" ,
626
618
"" ,
627
619
) ;
628
- assert ! ( db. insert_benchmark_request( & completed_try) . await . is_ok ( ) ) ;
620
+ db. insert_benchmark_request ( & completed_try) . await . unwrap ( ) ;
629
621
630
622
let try_benchmark_request = BenchmarkRequest :: create_try (
631
623
None ,
@@ -637,10 +629,9 @@ mod tests {
637
629
"" ,
638
630
) ;
639
631
// deliberately insert twice
640
- assert ! ( db
641
- . insert_benchmark_request( & try_benchmark_request)
632
+ db. insert_benchmark_request ( & try_benchmark_request)
642
633
. await
643
- . is_ok ( ) ) ;
634
+ . unwrap ( ) ;
644
635
// this one should fail
645
636
assert ! ( db
646
637
. insert_benchmark_request( & try_benchmark_request)
0 commit comments