From f2df090769c3ad0c64fa5511d4bc275b13c156dc Mon Sep 17 00:00:00 2001 From: dawn <90008@gaze.systems> Date: Fri, 20 Feb 2026 20:44:18 +0300 Subject: [PATCH] add fjall to --no-bulk --- src/bin/backfill.rs | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/bin/backfill.rs b/src/bin/backfill.rs index b76c07b..a7b1787 100644 --- a/src/bin/backfill.rs +++ b/src/bin/backfill.rs @@ -118,7 +118,15 @@ pub async fn run( let throttle = Duration::from_millis(upstream_throttle_ms); tasks.spawn(poll_upstream(None, upstream, throttle, poll_tx)); tasks.spawn(full_pages(poll_out, full_tx)); - tasks.spawn(pages_to_stdout(full_out, None)); + if let Some(fjall_path) = to_fjall { + log::trace!("opening fjall db at {fjall_path:?}..."); + let db = FjallDb::open(&fjall_path)?; + log::trace!("opened fjall db"); + + tasks.spawn(pages_to_fjall(db, full_out)); + } else { + tasks.spawn(pages_to_stdout(full_out, None)); + } } else { // fun mode -- 2.51.2