Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

changes to cli

This commit is contained in:
dal 2025-04-15 10:03:53 -06:00
parent 407e5dce92
commit 56ed9d1775
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
2 changed files with 47 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
cli/cli/src/commands/deploy.rs
View File

@ -1138,17 +1138,52 @@ pub async fn deploy(path: Option<&str>, dry_run: bool, recursive: bool) -> Resul
Err(e) => { Err(e) => {
println!("\n❌ Deployment failed!"); println!("\n❌ Deployment failed!");
// DEBUG: Print the raw error received from api.rs
println!("DEBUG: Raw error received: {:?}", e);
// Attempt to extract more detail from the error // Attempt to extract more detail from the error
let mut detailed_error = format!("{}", e); let mut detailed_error = format!("{}", e);
println!("DEBUG: Initial formatted error: {}", detailed_error);
if let Some(source) = e.source() { if let Some(source) = e.source() {
println!("DEBUG: Found error source: {:?}", source);
if let Some(reqwest_err) = source.downcast_ref::<reqwest::Error>() { if let Some(reqwest_err) = source.downcast_ref::<reqwest::Error>() {
println!("DEBUG: Source is reqwest::Error");
if let Some(status) = reqwest_err.status() { if let Some(status) = reqwest_err.status() {
detailed_error = format!("{} (HTTP Status: {})", detailed_error, status); println!("DEBUG: Extracted status from source: {}", status);
// Avoid appending status if it's already likely in the message from api.rs
// detailed_error = format!("{} (HTTP Status: {})", detailed_error, status);
} else {
println!("DEBUG: reqwest::Error has no status code");
}
} else {
println!(
"DEBUG: Source is not reqwest::Error: {:?}",
source // Print the source error directly
);
// Try digging deeper for reqwest::Error
let mut current_source = source;
while let Some(next_source) = current_source.source() {
println!("DEBUG: Deeper source: {:?}", next_source);
if let Some(reqwest_err) = next_source.downcast_ref::<reqwest::Error>()
{
println!("DEBUG: Found reqwest::Error deeper");
if let Some(status) = reqwest_err.status() {
println!(
"DEBUG: Extracted status from deeper source: {}",
status
);
}
break; // Found it
}
current_source = next_source;
} }
} }
} else {
println!("DEBUG: No error source found");
} }
println!("Error: {}", detailed_error); println!("Error: {}", detailed_error); // Final formatted error before troubleshooting tips
println!("\n💡 Troubleshooting:"); println!("\n💡 Troubleshooting:");
println!("1. Check data source:"); println!("1. Check data source:");
println!(" - Verify '{}' exists in Buster", data_source_name); println!(" - Verify '{}' exists in Buster", data_source_name);

14
cli/cli/src/utils/buster/api.rs
View File

@ -136,15 +136,21 @@ impl BusterClient {
{ {
Ok(res) => { Ok(res) => {
if !res.status().is_success() { if !res.status().is_success() {
let status = res.status();
let body = res.text().await?;
return Err(anyhow::anyhow!( return Err(anyhow::anyhow!(
"POST /api/v1/datasets/deploy failed: {}", "POST /api/v1/datasets/deploy failed with status {}: {}",
res.text().await? status,
body
)); ));
} }
Ok(res.json().await?) match res.json().await {
Ok(json_response) => Ok(json_response),
Err(e) => Err(anyhow::anyhow!("Failed to parse successful deploy response: {}", e)),
}
} }
Err(e) => Err(anyhow::anyhow!( Err(e) => Err(anyhow::anyhow!(
"POST /api/v1/datasets/deploy failed: {}", "POST /api/v1/datasets/deploy request failed: {}",
e e
)), )),
} }