From 6d2d040acdcfe43b1b9526658ffc512cf777d10e Mon Sep 17 00:00:00 2001 From: dawn Date: Thu, 6 Aug 2026 13:56:20 +0300 Subject: [PATCH] bobbin/crates/ingest: cover PendingOp::Identity in claim_pending and fix tests Signed-off-by: dawn --- bobbin/crates/ingest/src/lib.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/bobbin/crates/ingest/src/lib.rs b/bobbin/crates/ingest/src/lib.rs index 6f37e318..52ba279f 100644 --- a/bobbin/crates/ingest/src/lib.rs +++ b/bobbin/crates/ingest/src/lib.rs @@ -932,7 +932,7 @@ async fn claim_pending( ctx.resolver.forget(&ident.owner, &ident.rkey).await; } } - PendingOp::Noop | PendingOp::Parked { .. } => {} + PendingOp::Noop | PendingOp::Identity(_) | PendingOp::Parked { .. } => {} } pending } @@ -2825,6 +2825,7 @@ mod tests { #[tokio::test] async fn out_of_order_repo_preps_cannot_steal_a_rename() { let (store, issue_states, pull_statuses, cov, resolver) = fresh(); + let identity = IdentityResolver::detached(RuntimeHasher::default()); let search = NoopSearchSink; let records = NoopRecordStore; let ctx = PipelineCtx { @@ -2875,6 +2876,7 @@ mod tests { &search, &records, &resolver, + &identity, ) .await; let new_pending = resolve_pending(new_pending, &ctx).await; @@ -2887,6 +2889,7 @@ mod tests { &search, &records, &resolver, + &identity, ) .await; -- 2.51.2