fix: forward error messages triggering retry (#333)

This is for observability
bytebeamio · Apr 1, 2024 · 155fbaa · 155fbaa
1 parent 2f365e8
commit 155fbaa
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/uplink/src/collector/downloader.rs b/uplink/src/collector/downloader.rs
@@ -185,7 +185,13 @@ impl FileDownloader {
         loop {
             match self.download(req, &mut download).await {
                 Ok(_) => break,
-                Err(Error::Reqwest(e)) if !e.is_status() => error!("Download failed: {e}"),
+                Err(Error::Reqwest(e)) if !e.is_status() => {
+                    let status = ActionResponse::progress(&self.action_id, "Download Failed", 0)
+                        .set_sequence(self.sequence())
+                        .add_error(e.to_string());
+                    self.bridge_tx.send_action_response(status).await;
+                    error!("Download failed: {e}");
+                }
                 Err(e) => return Err(e),
             }
             tokio::time::sleep(Duration::from_secs(1)).await;