From bb905a30d871ea3b238c3bc5cfd1d96724c8d4eb Mon Sep 17 00:00:00 2001
From: Timon Vonk <timonv@gmail.com>
Date: Tue, 4 Jun 2024 20:21:05 +0200
Subject: [PATCH] fix: use rustls on redis and log errors

---
 crates/indexing/src/ingestion_pipeline.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/crates/indexing/src/ingestion_pipeline.rs b/crates/indexing/src/ingestion_pipeline.rs
index 9e6d7c34..6082f63f 100644
--- a/crates/indexing/src/ingestion_pipeline.rs
+++ b/crates/indexing/src/ingestion_pipeline.rs
@@ -40,8 +40,10 @@ impl IngestionPipeline {
             .try_filter(move |node| {
                 let cache = Arc::clone(&cache);
                 // FIXME: Maybe Cow or arc instead? Lots of nodes
+                // Or we could get the key before the spawn
                 let node = node.clone();
                 tokio::spawn(async move {
+                    let node = Arc::new(&node);
                     if !cache.get(&node).await {
                         cache.set(&node).await;
 
@@ -53,7 +55,10 @@ impl IngestionPipeline {
                         false
                     }
                 })
-                .unwrap_or_else(|_e| true)
+                .unwrap_or_else(|e| {
+                    tracing::error!("Error filtering cached node: {:?}", e);
+                    true
+                })
             })
             .boxed();
         self