Skip to content
This repository has been archived by the owner on Jun 21, 2024. It is now read-only.

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
xvello committed Apr 24, 2024
1 parent d76ed2b commit c3226f5
Showing 1 changed file with 8 additions and 6 deletions.
14 changes: 8 additions & 6 deletions hook-common/src/pgqueue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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<JobParameters, JobMetadata> = queue
Expand Down Expand Up @@ -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<PgTransactionBatch<JobParameters, JobMetadata>> = queue
Expand Down

0 comments on commit c3226f5

Please sign in to comment.