diff --git a/lambdas/query-metrics/Cargo.toml b/lambdas/query-metrics/Cargo.toml
index 5abcfa0..70d3e10 100644
--- a/lambdas/query-metrics/Cargo.toml
+++ b/lambdas/query-metrics/Cargo.toml
@@ -19,7 +19,7 @@ anyhow = "1.0.79"
 aws-config = "1.1.2"
 aws-sdk-cloudwatch = "1.11.0"
 aws-sdk-config = "1.11.0"
-aws_lambda_events = { version = "0.12.0", default-features = false, features = ["eventbridge"] }
+aws_lambda_events = { version = "0.12.0" }
 base64 = "0.21.7"
 deltalake = { version = "0.16.5", features = ["datafusion", "s3"] }
 
diff --git a/lambdas/query-metrics/src/main.rs b/lambdas/query-metrics/src/main.rs
index a5f2232..9bfea17 100644
--- a/lambdas/query-metrics/src/main.rs
+++ b/lambdas/query-metrics/src/main.rs
@@ -2,7 +2,7 @@
 /// This lambda function will run configured datafusion queries and report results CloudWatch
 /// metrics.
 ///
-use aws_lambda_events::event::eventbridge::EventBridgeEvent;
+use aws_lambda_events::event::cloudwatch_events::CloudWatchEvent;
 use aws_sdk_cloudwatch::types::MetricDatum;
 use deltalake::datafusion::common::*;
 use deltalake::datafusion::execution::context::SessionContext;
@@ -13,7 +13,7 @@ use std::sync::Arc;
 
 mod config;
 
-async fn function_handler(_event: LambdaEvent<EventBridgeEvent>) -> Result<(), Error> {
+async fn function_handler(_event: LambdaEvent<CloudWatchEvent>) -> Result<(), Error> {
     let aws_config = aws_config::load_defaults(aws_config::BehaviorVersion::latest()).await;
     let cloudwatch = aws_sdk_cloudwatch::Client::new(&aws_config);