Skip to content

Commit 0aff89a

Browse files
committed
fix(pegboard): skip protocol version keys in runner pool backfill
1 parent 5c3d2c5 commit 0aff89a

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

engine/packages/pegboard/src/workflows/runner_pool_backfill.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,14 @@ async fn backfill_chunk(ctx: &ActivityCtx, input: &BackfillChunkInput) -> Result
9999
};
100100

101101
new_last_key = [entry.key(), &[0xff]].concat();
102+
if let Ok((_, _, leaf)) =
103+
runner_config_subspace.unpack::<(Id, String, usize)>(entry.key())
104+
{
105+
if leaf == universaldb::utils::keys::PROTOCOL_VERSION {
106+
continue;
107+
}
108+
}
109+
102110
entries.push(tx.read_entry::<keys::runner_config::DataKey>(&entry)?);
103111
}
104112

0 commit comments

Comments
 (0)