diff --git a/crates/lox-distributor/src/main.rs b/crates/lox-distributor/src/main.rs index 289540a..acd912c 100644 --- a/crates/lox-distributor/src/main.rs +++ b/crates/lox-distributor/src/main.rs @@ -124,14 +124,16 @@ async fn rdsys_request(rtype: ResourceInfo, tx: mpsc::Sender) { let mut interval = interval(Duration::from_secs(5)); loop { interval.tick().await; - let resources = request_resources( + let resources = match request_resources( rtype.endpoint.clone(), rtype.name.clone(), rtype.token.clone(), rtype.types.clone(), ) - .await - .unwrap(); + .await{ + Ok(resources)=> resources, + Err(e) => {println!("No resources received from rdsys: {:?}", e); continue}, + }; tx.send(resources).await.unwrap(); } } diff --git a/crates/rdsys-backend-api/src/lib.rs b/crates/rdsys-backend-api/src/lib.rs index 51e2bdc..3000fde 100644 --- a/crates/rdsys-backend-api/src/lib.rs +++ b/crates/rdsys-backend-api/src/lib.rs @@ -284,8 +284,7 @@ pub async fn request_resources( .header("Authorization", &auth_value) .body(json) .send() - .await - .unwrap(); + .await?; match response.status() { reqwest::StatusCode::OK => { fetched_resources = match response.json::().await {