diff --git a/src/activity_queue.rs b/src/activity_queue.rs index f470ed9..c6c5864 100644 --- a/src/activity_queue.rs +++ b/src/activity_queue.rs @@ -217,13 +217,12 @@ async fn send( text, )) } - Err(e) => { - debug!( - "Unable to connect to {}, aborting task {}: {}", - task.inbox, task.activity_id, e - ); - Ok(()) - } + Err(e) => Err(anyhow!( + "Queueing activity {} to {} for retry after connection failure: {}", + task.activity_id, + task.inbox, + e + )), } }