diff --git a/backend/src/monitor.rs b/backend/src/monitor.rs index c48ca5a87b..b421054c2d 100644 --- a/backend/src/monitor.rs +++ b/backend/src/monitor.rs @@ -732,16 +732,19 @@ pub async fn delete_expired_items(db: &DB) -> () { } #[cfg(not(feature = "enterprise"))] + let audit_retention_secs = 1 * 60 * 60 * 24 * 14; + + #[cfg(feature = "enterprise")] + let audit_retention_secs = 1 * 60 * 60 * 24 * 365; + + if let Err(e) = sqlx::query_scalar!( + "DELETE FROM audit WHERE timestamp <= now() - ($1::bigint::text || ' s')::interval", + audit_retention_secs, + ) + .fetch_all(db) + .await { - if let Err(e) = sqlx::query_scalar!( - "DELETE FROM audit WHERE timestamp <= now() - ($1::bigint::text || ' s')::interval", - SERVICE_LOG_RETENTION_SECS, - ) - .fetch_all(db) - .await - { - tracing::error!("Error deleting audit log on CE: {:?}", e); - } + tracing::error!("Error deleting audit log on CE: {:?}", e); } let job_retention_secs = *JOB_RETENTION_SECS.read().await;