style: cargo fmt
All checks were successful
build / check (push) Successful in 3m38s
build / clippy (push) Successful in 3m36s
build / test (push) Successful in 4m17s
build / fmt (push) Successful in 30s

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
2026-05-14 17:21:06 +03:00
parent dd98bf2343
commit 19f9e5a02c

View File

@@ -197,11 +197,13 @@ impl GiteaClient {
let mut label_sets: Vec<LabelSetQueue> = by_label_set
.into_iter()
.map(|(label_set, (queued_count, oldest_created_at))| LabelSetQueue {
label_set,
queued_count,
oldest_created_at,
})
.map(
|(label_set, (queued_count, oldest_created_at))| LabelSetQueue {
label_set,
queued_count,
oldest_created_at,
},
)
.collect();
// FIFO: oldest queued job first. Tie-break by label_set for stability.
label_sets.sort_by(|a, b| {
@@ -257,10 +259,7 @@ impl GiteaClient {
/// (labels, created_at) for each queued job. The created_at is the
/// run's timestamp — Gitea's per-job listing does not expose one, and
/// all jobs in a run were queued together for our purposes.
async fn poll_repo_queue(
&self,
repo: &str,
) -> anyhow::Result<Vec<(Vec<String>, String)>> {
async fn poll_repo_queue(&self, repo: &str) -> anyhow::Result<Vec<(Vec<String>, String)>> {
let url = self.api_url(&format!("/repos/{repo}/actions/runs"));
let body = self
.client