+1 -1

crates/feed/src/repo/duckdb/scrobble.rs

reviewed

··· 1 1 - use std::sync::Arc; 1 1 + use std::{sync::Arc, thread::sleep}; 2 2 3 3 use anyhow::Error; 4 4 use duckdb::{params, OptionalExt};

+1 -4

crates/feed/src/sync.rs

reviewed

··· 11 11 pub async fn sync_scrobbles(ddb: RepoImpl) -> Result<(), Error> { 12 12 tracing::info!("Starting scrobble synchronization..."); 13 13 14 14 - let (tx, mut rx) = tokio::sync::mpsc::channel::<PgRow>(500); 14 14 + let (tx, mut rx) = tokio::sync::mpsc::channel::<PgRow>(100); 15 15 16 16 let handle = tokio::spawn(async move { 17 17 let pool = PgPoolOptions::new() ··· 147 147 148 148 let repo = ddb.clone(); 149 149 repo.insert_scrobble(&did, &scrobble_uri, record).await?; 150 150 - 151 151 - // sleep a bit to avoid overwhelming the database 152 152 - tokio::time::sleep(std::time::Duration::from_millis(300)).await; 153 150 154 151 i += 1; 155 152 }