Skip to content

Commit ffe1c31

Browse files
committed
admin/delete_version: Enqueue background jobs in parallel
1 parent 616a2bd commit ffe1c31

File tree

1 file changed

+8
-7
lines changed

1 file changed

+8
-7
lines changed

src/bin/crates-admin/delete_version.rs

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -95,13 +95,14 @@ pub async fn run(opts: Opts) -> anyhow::Result<()> {
9595
let crate_name = &opts.crate_name;
9696

9797
info!(%crate_name, "Enqueuing index sync jobs");
98-
let job = jobs::SyncToGitIndex::new(crate_name);
99-
if let Err(error) = job.enqueue(&mut conn).await {
100-
warn!(%crate_name, ?error, "Failed to enqueue SyncToGitIndex job");
101-
}
102-
let job = jobs::SyncToSparseIndex::new(crate_name);
103-
if let Err(error) = job.enqueue(&mut conn).await {
104-
warn!(%crate_name, ?error, "Failed to enqueue SyncToSparseIndex job");
98+
let git_index_job = jobs::SyncToGitIndex::new(crate_name);
99+
let sparse_index_job = jobs::SyncToSparseIndex::new(crate_name);
100+
101+
if let Err(error) = tokio::try_join!(
102+
git_index_job.enqueue(&mut conn),
103+
sparse_index_job.enqueue(&mut conn),
104+
) {
105+
warn!(%crate_name, "Failed to enqueue background job: {error}");
105106
}
106107

107108
for version in &opts.versions {

0 commit comments

Comments
 (0)