better logging on replay fetch error

estuary · Sep 21, 2023 · 525372c · 525372c
1 parent 184b521
commit 525372c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/pull.rs b/src/pull.rs
@@ -209,7 +209,13 @@ async fn ingest_replays(
     let meta = serde_json::json!({ "parent_groups": lineage });
 
     for replay in replays {
-        let mut replay_json = fetcher.fetch_replay(&replay.id).await?;
+        let mut replay_json = match fetcher.fetch_replay(&replay.id).await {
+            Ok(rp) => rp,
+            Err(err) => {
+                tracing::warn!(?lineage, ?binding, ?replay, error = ?err, "failed to fetch replay");
+                return Err(err);
+            }
+        };
         replay_json
             .as_object_mut()
             .expect("replay must be an object")