Skip to content

Commit 616a2bd

Browse files
committed
admin/delete_crate: Enqueue background jobs in parallel
1 parent 61a5ea8 commit 616a2bd

File tree

1 file changed

+11
-15
lines changed

1 file changed

+11
-15
lines changed

src/bin/crates-admin/delete_crate.rs

Lines changed: 11 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -107,21 +107,17 @@ pub async fn run(opts: Opts) -> anyhow::Result<()> {
107107
info!("{name}: Skipped missing crate");
108108
};
109109

110-
info!("{name}: Enqueuing index sync jobs…");
111-
let job = jobs::SyncToGitIndex::new(name);
112-
if let Err(error) = job.enqueue(&mut conn).await {
113-
warn!("{name}: Failed to enqueue SyncToGitIndex job: {error}");
114-
}
115-
116-
let job = jobs::SyncToSparseIndex::new(name);
117-
if let Err(error) = job.enqueue(&mut conn).await {
118-
warn!("{name}: Failed to enqueue SyncToSparseIndex job: {error}");
119-
}
120-
121-
info!("{name}: Enqueuing DeleteCrateFromStorage job…");
122-
let job = jobs::DeleteCrateFromStorage::new(name.into());
123-
if let Err(error) = job.enqueue(&mut conn).await {
124-
warn!("{name}: Failed to enqueue DeleteCrateFromStorage job: {error}");
110+
info!("{name}: Enqueuing background jobs…");
111+
let git_index_job = jobs::SyncToGitIndex::new(name);
112+
let sparse_index_job = jobs::SyncToSparseIndex::new(name);
113+
let delete_from_storage_job = jobs::DeleteCrateFromStorage::new(name.into());
114+
115+
if let Err(error) = tokio::try_join!(
116+
git_index_job.enqueue(&mut conn),
117+
sparse_index_job.enqueue(&mut conn),
118+
delete_from_storage_job.enqueue(&mut conn),
119+
) {
120+
warn!("{name}: Failed to enqueue background job: {error}");
125121
}
126122
}
127123

0 commit comments

Comments
 (0)