diff --git a/hook-common/src/pgqueue.rs b/hook-common/src/pgqueue.rs index f155506..5d8a144 100644 --- a/hook-common/src/pgqueue.rs +++ b/hook-common/src/pgqueue.rs @@ -827,14 +827,15 @@ mod tests { let retry_interval = retry_policy.retry_interval(job.job.attempt as u32, None); let retry_queue = retry_policy.retry_queue(&job.job.queue).to_owned(); - let _ = job - .retry( + drop( + job.retry( "a very reasonable failure reason", retry_interval, &retry_queue, ) .await - .expect("failed to retry job"); + .expect("failed to retry job"), + ); batch.commit().await.expect("failed to commit transaction"); let retried_job: PgTransactionJob = queue @@ -883,14 +884,15 @@ mod tests { let retry_interval = retry_policy.retry_interval(job.job.attempt as u32, None); let retry_queue = retry_policy.retry_queue(&job.job.queue).to_owned(); - let _ = job - .retry( + drop( + job.retry( "a very reasonable failure reason", retry_interval, &retry_queue, ) .await - .expect("failed to retry job"); + .expect("failed to retry job"), + ); batch.commit().await.expect("failed to commit transaction"); let retried_job_not_found: Option> = queue