Skip to content

Commit

Permalink
cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
daidokoro committed Nov 19, 2024
1 parent bcc5b64 commit 290c204
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions src/logs/process.rs
Original file line number Diff line number Diff line change
Expand Up @@ -193,14 +193,16 @@ pub async fn kinesis_logs(

// String::from_utf8(decompressed_data.clone())?;
let batches = match serde_json::from_str(&decoded_data) {
Ok(logs) => process_cloudwatch_logs(logs, config.sampling, &config.blocking_pattern).await?,
Ok(logs) => {
process_cloudwatch_logs(logs, config.sampling, &config.blocking_pattern).await?
}
Err(_) => {
tracing::error!("Failed to decode data");
if decoded_data.is_empty() {
if decoded_data.is_empty() {
Vec::new()
} else {
vec![decoded_data]
}
}
}
};

Expand Down

0 comments on commit 290c204

Please sign in to comment.