diff --git a/src/ingest.rs b/src/ingest.rs index f41fbe7..2169706 100644 --- a/src/ingest.rs +++ b/src/ingest.rs @@ -434,7 +434,6 @@ mod tests { Some(6789.0), ], extra_fields: HashMap::new(), - status_array: vec![], }, } } diff --git a/src/main.rs b/src/main.rs index 15687f4..3b643bf 100644 --- a/src/main.rs +++ b/src/main.rs @@ -14,7 +14,7 @@ use tokio::net::TcpListener; use tracing_subscriber::EnvFilter; fn init_logging() { - let filter = EnvFilter::from_default_env(); + let filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info")); if std::env::var("HAGFISH_LOG_FORMAT").as_deref() == Ok("json") { tracing_subscriber::fmt() @@ -34,10 +34,11 @@ fn cleanup_stale_parquet_files() { if let Some(name) = entry.file_name().to_str() { if name.starts_with("hagfish-") && name.ends_with(".parquet") { if let Ok(metadata) = entry.metadata() { - let age = std::time::SystemTime::now() - .duration_since(metadata.modified().unwrap()); - if age.map(|d| d.as_secs() > 3600).unwrap_or(false) { - let _ = std::fs::remove_file(entry.path()); + if let Ok(modified) = metadata.modified() { + let age = std::time::SystemTime::now().duration_since(modified); + if age.map(|d| d.as_secs() > 3600).unwrap_or(false) { + let _ = std::fs::remove_file(entry.path()); + } } } }