Skip to content

fix: dragonsmouth-from-slot '*' falls back to gRPC slot on empty blocks_metadata #58

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
gamandeepsingh wants to merge 1 commit into
base: main
Choose a base branch
from
Open

fix: dragonsmouth-from-slot '*' falls back to gRPC slot on empty blocks_metadata #58

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion crates/superbank/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,9 @@ cargo run -p superbank -- --config path/to/superbank.yaml
- `dragonsmouth-from-slot: 0` attempts slot 0; if unavailable, superbank parses the gRPC error to
find the earliest available slot.
- `dragonsmouth-from-slot: "*"` uses the highest slot in `blocks_metadata` before subscribing; if
rejected, superbank falls back to the gRPC-reported available slot.
rejected, superbank falls back to the gRPC-reported available slot. If `blocks_metadata` has no
rows yet (fresh deployment), superbank skips straight to that same gRPC-reported available slot
instead of erroring.
- For seeded live-tail gRPC deployments, prefer `dragonsmouth-from-slot: "*"` so process restarts
resume from the latest durable ClickHouse slot instead of replaying from the earliest available
upstream slot.
Expand Down
30 changes: 17 additions & 13 deletions crates/superbank/src/ingest/grpc.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -483,20 +483,24 @@ async fn resolve_initial_from_slot(
) -> Result<(Option<u64>, Option<FromSlotMode>)> {
match args.dragonsmouth_from_slot {
Some(FromSlotSpec::LatestDb) => {
let latest = fetch_latest_slot_from_blocks(clickhouse, &args.blocks_table)
.await?
.ok_or_else(|| {
anyhow!(
"dragonsmouth-from-slot '*' requires at least one row in {}",
match fetch_latest_slot_from_blocks(clickhouse, &args.blocks_table).await? {
Some(latest) => {
info!(
slot = latest,
table = %args.blocks_table,
"resolved dragonsmouth-from-slot='*' to latest slot in blocks_metadata"
);
Ok((Some(latest), Some(FromSlotMode::LatestDb)))
}
None => {
info!(
table = %args.blocks_table,
"dragonsmouth-from-slot='*' found no rows in {}; falling back to gRPC-reported available slot",
args.blocks_table
)
})?;
info!(
slot = latest,
table = %args.blocks_table,
"resolved dragonsmouth-from-slot='*' to latest slot in blocks_metadata"
);
Ok((Some(latest), Some(FromSlotMode::LatestDb)))
);
Ok((None, Some(FromSlotMode::LatestDb)))
}
}
}
Some(FromSlotSpec::Slot(0)) => Ok((Some(0), Some(FromSlotMode::Zero))),
Some(FromSlotSpec::Slot(slot)) => Ok((Some(slot), Some(FromSlotMode::Strict))),
Expand Down
Loading