diff --git a/examples/advanced-appconfig-feature-flags/Cargo.toml b/examples/advanced-appconfig-feature-flags/Cargo.toml
index 52ebb843..51b708ec 100644
--- a/examples/advanced-appconfig-feature-flags/Cargo.toml
+++ b/examples/advanced-appconfig-feature-flags/Cargo.toml
@@ -15,10 +15,10 @@ edition = "2021"
 # and it will keep the alphabetic ordering for you.
 
 [dependencies]
-async-trait = "0.1.68"
-lambda_runtime = "0.13"
-reqwest = { version = "0.11", default-features = false, features = ["json", "rustls-tls"] }
+async-trait = "0.1.88"
+lambda_runtime = { path = "../../lambda-runtime" }
+reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls"] }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
-thiserror = "1.0"
+thiserror = "2.0"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/advanced-appconfig-feature-flags/src/main.rs b/examples/advanced-appconfig-feature-flags/src/main.rs
index b7d5e515..87ec54fa 100644
--- a/examples/advanced-appconfig-feature-flags/src/main.rs
+++ b/examples/advanced-appconfig-feature-flags/src/main.rs
@@ -35,9 +35,9 @@ async fn function_handler<T: ConfigurationFetcher + Send + Sync>(
 
     // Use the feature flag
     let msg = if config.spanish_response {
-        format!("{}, in spanish.", quote)
+        format!("{quote}, in spanish.")
     } else {
-        format!("{}.", quote)
+        format!("{quote}.")
     };
 
     // Return `Response` (it will be serialized to JSON automatically by the runtime)
diff --git a/examples/advanced-sqs-multiple-functions-shared-data/consumer/Cargo.toml b/examples/advanced-sqs-multiple-functions-shared-data/consumer/Cargo.toml
index 69ec04a0..e82dc1d3 100644
--- a/examples/advanced-sqs-multiple-functions-shared-data/consumer/Cargo.toml
+++ b/examples/advanced-sqs-multiple-functions-shared-data/consumer/Cargo.toml
@@ -5,9 +5,7 @@ edition = "2021"
 
 [dependencies]
 #aws dependencies
-aws-sdk-config = "0.35.0"
-aws-sdk-sqs = "0.35.0"
-aws_lambda_events = { version = "0.11.1", features = ["sqs"], default-features = false }
+aws_lambda_events = { path = "../../../lambda-events", features = ["sqs"], default-features = false }
 
 #lambda runtime
 lambda_runtime = { path = "../../../lambda-runtime" }
diff --git a/examples/advanced-sqs-multiple-functions-shared-data/pizza_lib/Cargo.toml b/examples/advanced-sqs-multiple-functions-shared-data/pizza_lib/Cargo.toml
index 76631bbd..2dd69db1 100644
--- a/examples/advanced-sqs-multiple-functions-shared-data/pizza_lib/Cargo.toml
+++ b/examples/advanced-sqs-multiple-functions-shared-data/pizza_lib/Cargo.toml
@@ -4,4 +4,4 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-serde = { version = "1.0.191", features = ["derive"] }
+serde = { version = "1.0.219", features = ["derive"] }
diff --git a/examples/advanced-sqs-multiple-functions-shared-data/producer/Cargo.toml b/examples/advanced-sqs-multiple-functions-shared-data/producer/Cargo.toml
index 83aa48ab..2772f650 100644
--- a/examples/advanced-sqs-multiple-functions-shared-data/producer/Cargo.toml
+++ b/examples/advanced-sqs-multiple-functions-shared-data/producer/Cargo.toml
@@ -8,14 +8,13 @@ env = { "QUEUE_URL" = "https://changeMe" }
 
 [dependencies]
 #aws dependencies
-aws-config = "0.57.1"
-aws-sdk-config = "0.35.0"
-aws-sdk-sqs = "0.35.0"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-sdk-sqs = "1.74.0"
 
 #lambda runtime
 lambda_runtime = { path = "../../../lambda-runtime" }
-serde_json = "1.0.108"
+serde_json = "1.0.140"
 tokio = { version = "1", features = ["macros"] }
 
 #shared lib
-pizza_lib = { path = "../pizza_lib" }
\ No newline at end of file
+pizza_lib = { path = "../pizza_lib" }
diff --git a/examples/advanced-sqs-multiple-functions-shared-data/producer/src/main.rs b/examples/advanced-sqs-multiple-functions-shared-data/producer/src/main.rs
index 2a70dce3..6a2883f3 100644
--- a/examples/advanced-sqs-multiple-functions-shared-data/producer/src/main.rs
+++ b/examples/advanced-sqs-multiple-functions-shared-data/producer/src/main.rs
@@ -20,7 +20,7 @@ async fn main() -> Result<(), Error> {
     // read the queue url from the environment
     let queue_url = std::env::var("QUEUE_URL").expect("could not read QUEUE_URL");
     // build the config from environment variables (fed by AWS Lambda)
-    let config = aws_config::from_env().load().await;
+    let config = aws_config::load_from_env().await;
     // create our SQS Manager
     let sqs_manager = SQSManager::new(aws_sdk_sqs::Client::new(&config), queue_url);
     let sqs_manager_ref = &sqs_manager;
diff --git a/examples/advanced-sqs-partial-batch-failures/Cargo.toml b/examples/advanced-sqs-partial-batch-failures/Cargo.toml
index 95050b9a..f02e4efb 100644
--- a/examples/advanced-sqs-partial-batch-failures/Cargo.toml
+++ b/examples/advanced-sqs-partial-batch-failures/Cargo.toml
@@ -5,8 +5,6 @@ edition = "2021"
 
 [dependencies]
 serde = "^1"
-serde_derive = "^1"
-serde_with = { version = "^2", features = ["json"], optional = true }
 serde_json = "^1"
 aws_lambda_events = { path = "../../lambda-events" }
 lambda_runtime = { path = "../../lambda-runtime" }
diff --git a/examples/advanced-sqs-partial-batch-failures/src/main.rs b/examples/advanced-sqs-partial-batch-failures/src/main.rs
index be4eb66f..6cea2f93 100644
--- a/examples/advanced-sqs-partial-batch-failures/src/main.rs
+++ b/examples/advanced-sqs-partial-batch-failures/src/main.rs
@@ -55,7 +55,7 @@ where
     D: DeserializeOwned,
     R: Future<Output = Result<(), Error>>,
 {
-    run(service_fn(|e| batch_handler(|d| f(d), e))).await
+    run(service_fn(|e| batch_handler(&f, e))).await
 }
 
 /// Helper function to lift the user provided `f` function from message to batch of messages.
@@ -123,7 +123,7 @@ mod test {
     }
 
     #[tokio::test]
-    async fn test() -> () {
+    async fn test() {
         let msg_to_fail: SqsMessageObj<serde_json::Value> = serde_json::from_str(
             r#"{
                 "messageId": "1",
diff --git a/examples/basic-cognito-post-confirmation/Cargo.toml b/examples/basic-cognito-post-confirmation/Cargo.toml
index 7d2e7ab4..93369e51 100644
--- a/examples/basic-cognito-post-confirmation/Cargo.toml
+++ b/examples/basic-cognito-post-confirmation/Cargo.toml
@@ -15,8 +15,8 @@ edition = "2021"
 # and it will keep the alphabetic ordering for you.
 
 [dependencies]
-aws-config = "1.5.0"
-aws-sdk-ses = "1.28.0"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-sdk-ses = "1.77.0"
 aws_lambda_events = { path = "../../lambda-events", default-features = false, features = ["cognito"] }
 
 lambda_runtime = { path = "../../lambda-runtime" }
diff --git a/examples/basic-error-error-crates-integration/Cargo.toml b/examples/basic-error-error-crates-integration/Cargo.toml
index 741ec713..24fbc8dc 100644
--- a/examples/basic-error-error-crates-integration/Cargo.toml
+++ b/examples/basic-error-error-crates-integration/Cargo.toml
@@ -7,6 +7,6 @@ edition = "2021"
 anyhow = "1"
 eyre = "0.6.12"
 lambda_runtime = { path = "../../lambda-runtime", features = ["anyhow", "eyre", "miette"] }
-miette = "7.2.0"
+miette = "7.6.0"
 serde = "1"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/basic-error-error-crates-integration/src/main.rs b/examples/basic-error-error-crates-integration/src/main.rs
index f4048584..176bd54b 100644
--- a/examples/basic-error-error-crates-integration/src/main.rs
+++ b/examples/basic-error-error-crates-integration/src/main.rs
@@ -28,7 +28,7 @@ fn miette_error() -> miette::Result<()> {
 
 /// Transform an anyhow::Error, eyre::Report, or miette::Report into a lambda_runtime::Diagnostic.
 /// It does it by enabling the feature `anyhow`, `eyre` or `miette` in the runtime dependency.
-/// Those features enable the implementation of `From<T> for Diagnostic` 
+/// Those features enable the implementation of `From<T> for Diagnostic`
 /// for `anyhow::Error`, `eyre::Report`, and `miette::Report`.
 async fn function_handler(event: LambdaEvent<Request>) -> Result<(), Diagnostic> {
     match event.payload.error_type {
diff --git a/examples/basic-error-handling/Cargo.toml b/examples/basic-error-handling/Cargo.toml
index 1039a139..a0267f97 100644
--- a/examples/basic-error-handling/Cargo.toml
+++ b/examples/basic-error-handling/Cargo.toml
@@ -5,7 +5,7 @@ edition = "2021"
 
 [dependencies]
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.136"
-serde_json = "1.0.81"
-simple-error = "0.2.3"
+serde = "1.0.219"
+serde_json = "1.0.140"
+simple-error = "0.3.1"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/basic-error-handling/src/main.rs b/examples/basic-error-handling/src/main.rs
index 12c954a9..85e97428 100644
--- a/examples/basic-error-handling/src/main.rs
+++ b/examples/basic-error-handling/src/main.rs
@@ -43,7 +43,7 @@ impl std::fmt::Display for CustomError {
     /// Display the error struct as a JSON string
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         let err_as_json = json!(self).to_string();
-        write!(f, "{}", err_as_json)
+        write!(f, "{err_as_json}")
     }
 }
 
@@ -66,7 +66,7 @@ pub(crate) async fn func(event: LambdaEvent<Request>) -> Result<Response, Error>
     match event.event_type {
         EventType::SimpleError => {
             // generate a simple text message error using `simple_error` crate
-            return Err(Box::new(simple_error::SimpleError::new("A simple error as requested!")));
+            Err(Box::new(simple_error::SimpleError::new("A simple error as requested!")))
         }
         EventType::CustomError => {
             // generate a custom error using our own structure
@@ -75,7 +75,7 @@ pub(crate) async fn func(event: LambdaEvent<Request>) -> Result<Response, Error>
                 req_id: ctx.request_id,
                 msg: "A custom error as requested!".into(),
             };
-            return Err(Box::new(cust_err));
+            Err(Box::new(cust_err))
         }
         EventType::ExternalError => {
             // try to open a non-existent file to get an error and propagate it with `?`
@@ -94,7 +94,7 @@ pub(crate) async fn func(event: LambdaEvent<Request>) -> Result<Response, Error>
                 msg: "OK".into(),
             };
 
-            return Ok(resp);
+            Ok(resp)
         }
     }
 }
diff --git a/examples/basic-error-thiserror/Cargo.toml b/examples/basic-error-thiserror/Cargo.toml
index d7c7d725..f2b0b449 100644
--- a/examples/basic-error-thiserror/Cargo.toml
+++ b/examples/basic-error-thiserror/Cargo.toml
@@ -18,5 +18,5 @@ edition = "2021"
 
 lambda_runtime = { path = "../../lambda-runtime" }
 serde = "1"
-thiserror = "1.0.61"
+thiserror = "2.0"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/basic-error-thiserror/src/main.rs b/examples/basic-error-thiserror/src/main.rs
index 403309bf..2c01b833 100644
--- a/examples/basic-error-thiserror/src/main.rs
+++ b/examples/basic-error-thiserror/src/main.rs
@@ -1,6 +1,5 @@
 use lambda_runtime::{service_fn, Diagnostic, Error, LambdaEvent};
 use serde::Deserialize;
-use thiserror;
 
 #[derive(Deserialize)]
 struct Request {}
@@ -21,7 +20,7 @@ impl From<ExecutionError> for Diagnostic {
         };
         Diagnostic {
             error_type: error_type.into(),
-            error_message: error_message.into(),
+            error_message,
         }
     }
 }
diff --git a/examples/basic-lambda-external-runtime/Cargo.toml b/examples/basic-lambda-external-runtime/Cargo.toml
index d6d023d8..40f24d81 100644
--- a/examples/basic-lambda-external-runtime/Cargo.toml
+++ b/examples/basic-lambda-external-runtime/Cargo.toml
@@ -4,11 +4,8 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-async-channel = "1.8.0"
-futures-lite = "1.13.0"
+async-channel = "2.5.0"
+futures-lite = "2.6.0"
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.163"
-tokio = "1.28.2"
-
-[dev-dependencies]
-tokio-test = "0.4.2"
+serde = "1.0.219"
+tokio = "1.46.1"
diff --git a/examples/basic-lambda-external-runtime/src/main.rs b/examples/basic-lambda-external-runtime/src/main.rs
index bd3b4e6c..87891ebc 100644
--- a/examples/basic-lambda-external-runtime/src/main.rs
+++ b/examples/basic-lambda-external-runtime/src/main.rs
@@ -53,7 +53,7 @@ fn main() -> Result<(), io::Error> {
     my_runtime(move || future::block_on(app_runtime_task(lambda_rx.clone(), shutdown_tx.clone())));
 
     // Block the main thread until a shutdown signal is received.
-    future::block_on(shutdown_rx.recv()).map_err(|err| io::Error::new(io::ErrorKind::Other, format!("{:?}", err)))
+    future::block_on(shutdown_rx.recv()).map_err(|err| io::Error::other(format!("{err:?}")))
 }
 
 pub(crate) async fn my_handler(event: LambdaEvent<Request>) -> Result<Response, Error> {
@@ -63,7 +63,7 @@ pub(crate) async fn my_handler(event: LambdaEvent<Request>) -> Result<Response,
     // prepare the response
     let resp = Response {
         req_id: event.context.request_id,
-        msg: format!("Command {} executed.", command),
+        msg: format!("Command {command} executed."),
     };
 
     // return `Response` (it will be serialized to JSON automatically by the runtime)
diff --git a/examples/basic-lambda/Cargo.toml b/examples/basic-lambda/Cargo.toml
index 6fad6990..afc727c4 100644
--- a/examples/basic-lambda/Cargo.toml
+++ b/examples/basic-lambda/Cargo.toml
@@ -5,8 +5,5 @@ edition = "2021"
 
 [dependencies]
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.136"
+serde = "1.0.219"
 tokio = { version = "1", features = ["macros"] }
-
-[dev-dependencies]
-tokio-test = "0.4.2"
\ No newline at end of file
diff --git a/examples/basic-lambda/src/main.rs b/examples/basic-lambda/src/main.rs
index 8630e78c..d3f2a3cd 100644
--- a/examples/basic-lambda/src/main.rs
+++ b/examples/basic-lambda/src/main.rs
@@ -39,7 +39,7 @@ pub(crate) async fn my_handler(event: LambdaEvent<Request>) -> Result<Response,
     // prepare the response
     let resp = Response {
         req_id: event.context.request_id,
-        msg: format!("Command {} executed.", command),
+        msg: format!("Command {command} executed."),
     };
 
     // return `Response` (it will be serialized to JSON automatically by the runtime)
diff --git a/examples/basic-s3-object-lambda-thumbnail/Cargo.toml b/examples/basic-s3-object-lambda-thumbnail/Cargo.toml
index 905362c9..09d8a4b2 100644
--- a/examples/basic-s3-object-lambda-thumbnail/Cargo.toml
+++ b/examples/basic-s3-object-lambda-thumbnail/Cargo.toml
@@ -15,19 +15,16 @@ edition = "2021"
 # and it will keep the alphabetic ordering for you.
 
 [dependencies]
-aws_lambda_events = "0.8.3"
+aws_lambda_events = { path = "../../lambda-events" }
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1"
 tokio = { version = "1", features = ["macros"] }
-aws-config = "0.55.3"
-aws-sdk-s3 = "0.28.0"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-sdk-s3 = "1.96.0"
 thumbnailer = "0.5.1"
-mime = "0.3.16"
-async-trait = "0.1.66"
-ureq = "2.6.2"
-aws-smithy-http = "0.55.3"
-webp = "=0.2.1"
+mime = "0.3.17"
+async-trait = "0.1.88"
+ureq = "3.0.12"
 
 [dev-dependencies]
-mockall = "0.11.3"
-tokio-test = "0.4.2"
+serde_json = "1.0.140"
+mockall = "0.13.1"
diff --git a/examples/basic-s3-object-lambda-thumbnail/src/main.rs b/examples/basic-s3-object-lambda-thumbnail/src/main.rs
index bb1c4f9c..699fb044 100644
--- a/examples/basic-s3-object-lambda-thumbnail/src/main.rs
+++ b/examples/basic-s3-object-lambda-thumbnail/src/main.rs
@@ -84,30 +84,25 @@ fn get_thumbnail(vec: Vec<u8>, _size: u32) -> Vec<u8> {
 mod tests {
     use super::*;
     use async_trait::async_trait;
-    use aws_lambda_events::s3::object_lambda::Configuration;
-    use aws_lambda_events::s3::object_lambda::HeadObjectContext;
-    use aws_lambda_events::s3::object_lambda::ListObjectsContext;
-    use aws_lambda_events::s3::object_lambda::ListObjectsV2Context;
-    use aws_lambda_events::s3::object_lambda::UserIdentity;
-    use aws_lambda_events::s3::object_lambda::UserRequest;
-    use aws_lambda_events::serde_json::json;
+    use aws_lambda_events::s3::object_lambda::{
+        Configuration, HeadObjectContext, ListObjectsContext, ListObjectsV2Context, UserIdentity, UserRequest,
+    };
     use lambda_runtime::{Context, LambdaEvent};
     use mockall::mock;
-    use s3::GetFile;
-    use s3::SendFile;
+    use s3::{GetFile, SendFile};
+    use serde_json::json;
 
     #[tokio::test]
     async fn response_is_good() {
         mock! {
             FakeS3Client {}
 
-            #[async_trait]
             impl GetFile for FakeS3Client {
-                pub fn get_file(&self, url: String) -> Result<Vec<u8>, Box<dyn error::Error>>;
+                fn get_file(&self, url: String) -> Result<Vec<u8>, Box<dyn error::Error>>;
             }
             #[async_trait]
             impl SendFile for FakeS3Client {
-                pub async fn send_file(&self, route: String, token: String, vec: Vec<u8>) -> Result<String, Box<dyn error::Error>>;
+                async fn send_file(&self, route: String, token: String, vec: Vec<u8>) -> Result<String, Box<dyn error::Error>>;
             }
         }
 
@@ -118,9 +113,7 @@ mod tests {
             .returning(|_1| Ok("IMAGE".into()));
 
         mock.expect_send_file()
-            .withf(|r, t, by| {
-                return r.eq("O_ROUTE") && t.eq("O_TOKEN") && by == "THUMBNAIL".as_bytes();
-            })
+            .withf(|r, t, by| r.eq("O_ROUTE") && t.eq("O_TOKEN") && by == "THUMBNAIL".as_bytes())
             .returning(|_1, _2, _3| Ok("File sent.".to_string()));
 
         let payload = get_s3_event();
@@ -133,7 +126,7 @@ mod tests {
     }
 
     fn get_s3_event() -> S3ObjectLambdaEvent {
-        return S3ObjectLambdaEvent {
+        S3ObjectLambdaEvent {
             x_amz_request_id: ("ID".to_string()),
             head_object_context: (Some(HeadObjectContext::default())),
             list_objects_context: (Some(ListObjectsContext::default())),
@@ -151,6 +144,6 @@ mod tests {
                 supporting_access_point_arn: ("SAPRN".to_string()),
                 payload: (json!(null)),
             }),
-        };
+        }
     }
 }
diff --git a/examples/basic-s3-object-lambda-thumbnail/src/s3.rs b/examples/basic-s3-object-lambda-thumbnail/src/s3.rs
index daba3739..69b46ec2 100644
--- a/examples/basic-s3-object-lambda-thumbnail/src/s3.rs
+++ b/examples/basic-s3-object-lambda-thumbnail/src/s3.rs
@@ -1,6 +1,8 @@
 use async_trait::async_trait;
-use aws_sdk_s3::{operation::write_get_object_response::WriteGetObjectResponseError, Client as S3Client};
-use aws_smithy_http::{byte_stream::ByteStream, result::SdkError};
+use aws_sdk_s3::{
+    error::SdkError, operation::write_get_object_response::WriteGetObjectResponseError, primitives::ByteStream,
+    Client as S3Client,
+};
 use lambda_runtime::tracing;
 use std::{error, io::Read};
 
@@ -17,12 +19,17 @@ impl GetFile for S3Client {
     fn get_file(&self, url: String) -> Result<Vec<u8>, Box<dyn error::Error>> {
         tracing::info!("get file url {}", url);
 
-        let resp = ureq::get(&url).call()?;
-        let len: usize = resp.header("Content-Length").unwrap().parse()?;
+        let mut res = ureq::get(&url).call()?;
+        let len: usize = res
+            .headers()
+            .get("Content-Length")
+            .and_then(|h| h.to_str().ok())
+            .and_then(|s| s.parse().ok())
+            .unwrap();
 
         let mut bytes: Vec<u8> = Vec::with_capacity(len);
 
-        std::io::Read::take(resp.into_reader(), 10_000_000).read_to_end(&mut bytes)?;
+        std::io::Read::take(res.body_mut().as_reader(), 10_000_000).read_to_end(&mut bytes)?;
 
         tracing::info!("got {} bytes", bytes.len());
 
@@ -46,9 +53,8 @@ impl SendFile for S3Client {
             .send()
             .await;
 
-        if write.is_err() {
-            let sdk_error = write.err().unwrap();
-            check_error(sdk_error);
+        if let Err(err) = write {
+            check_error(err);
             Err("WriteGetObjectResponse creation error".into())
         } else {
             Ok("File sent.".to_string())
@@ -65,16 +71,16 @@ fn check_error(error: SdkError<WriteGetObjectResponseError>) {
             tracing::info!("DispatchFailure");
             if err.is_io() {
                 tracing::info!("IO error");
-            };
+            }
             if err.is_timeout() {
                 tracing::info!("Timeout error");
-            };
+            }
             if err.is_user() {
                 tracing::info!("User error");
-            };
-            if err.is_other().is_some() {
+            }
+            if err.is_other() {
                 tracing::info!("Other error");
-            };
+            }
         }
         SdkError::ResponseError(_err) => tracing::info!("ResponseError"),
         SdkError::TimeoutError(_err) => tracing::info!("TimeoutError"),
diff --git a/examples/basic-s3-thumbnail/Cargo.toml b/examples/basic-s3-thumbnail/Cargo.toml
index 4b9ef3da..fdbd79be 100644
--- a/examples/basic-s3-thumbnail/Cargo.toml
+++ b/examples/basic-s3-thumbnail/Cargo.toml
@@ -17,17 +17,13 @@ edition = "2021"
 [dependencies]
 aws_lambda_events = { path = "../../lambda-events" }
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1"
 tokio = { version = "1", features = ["macros"] }
-aws-config = "0.55"
-aws-smithy-http = "0.55.3"
-aws-sdk-s3 = "0.28"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-sdk-s3 = "1.96.0"
 thumbnailer = "0.5.1"
-mime = "0.3.16"
-async-trait = "0.1.68"
-webp = "=0.2.1"
+mime = "0.3.17"
+async-trait = "0.1.88"
 
 [dev-dependencies]
-mockall = "0.11"
-tokio-test = "0.4"
+mockall = "0.13.1"
 chrono = "0.4"
diff --git a/examples/basic-s3-thumbnail/src/main.rs b/examples/basic-s3-thumbnail/src/main.rs
index 3eb5bfe9..d09da116 100644
--- a/examples/basic-s3-thumbnail/src/main.rs
+++ b/examples/basic-s3-thumbnail/src/main.rs
@@ -139,16 +139,11 @@ mod tests {
     use super::*;
     use async_trait::async_trait;
     //use aws_lambda_events::chrono::DateTime;
-    use aws_lambda_events::s3::S3Bucket;
-    use aws_lambda_events::s3::S3Entity;
-    use aws_lambda_events::s3::S3Object;
-    use aws_lambda_events::s3::S3RequestParameters;
-    use aws_lambda_events::s3::S3UserIdentity;
+    use aws_lambda_events::s3::{S3Bucket, S3Entity, S3Object, S3RequestParameters, S3UserIdentity};
     use aws_sdk_s3::operation::get_object::GetObjectError;
     use lambda_runtime::{Context, LambdaEvent};
     use mockall::mock;
-    use s3::GetFile;
-    use s3::PutFile;
+    use s3::{GetFile, PutFile};
 
     #[tokio::test]
     async fn response_is_good() {
@@ -163,11 +158,11 @@ mod tests {
 
             #[async_trait]
             impl GetFile for FakeS3Client {
-                pub async fn get_file(&self, bucket: &str, key: &str) -> Result<Vec<u8>, GetObjectError>;
+                async fn get_file(&self, bucket: &str, key: &str) -> Result<Vec<u8>, GetObjectError>;
             }
             #[async_trait]
             impl PutFile for FakeS3Client {
-                pub async fn put_file(&self, bucket: &str, key: &str, bytes: Vec<u8>) -> Result<String, String>;
+                async fn put_file(&self, bucket: &str, key: &str, bytes: Vec<u8>) -> Result<String, String>;
             }
         }
 
@@ -178,23 +173,21 @@ mod tests {
             .returning(|_1, _2| Ok("IMAGE".into()));
 
         mock.expect_put_file()
-            .withf(|bu, ke, by| {
-                return bu.eq("test-bucket-thumbs") && ke.eq(key) && by.eq("THUMBNAIL".as_bytes());
-            })
+            .withf(|bu, ke, by| bu.eq("test-bucket-thumbs") && ke.eq(key) && by.eq("THUMBNAIL".as_bytes()))
             .return_const(Ok("Done".to_string()));
 
         let payload = get_s3_event("ObjectCreated", bucket, key);
         let event = LambdaEvent { payload, context };
 
-        let result = function_handler(event, 10, &mock).await.unwrap();
+        function_handler(event, 10, &mock).await.unwrap();
 
-        assert_eq!((), result);
+        assert_eq!((), ());
     }
 
     fn get_s3_event(event_name: &str, bucket_name: &str, object_key: &str) -> S3Event {
-        return S3Event {
+        S3Event {
             records: (vec![get_s3_event_record(event_name, bucket_name, object_key)]),
-        };
+        }
     }
 
     fn get_s3_event_record(event_name: &str, bucket_name: &str, object_key: &str) -> S3EventRecord {
@@ -218,7 +211,7 @@ mod tests {
             }),
         };
 
-        return S3EventRecord {
+        S3EventRecord {
             event_version: (Some(String::default())),
             event_source: (Some(String::default())),
             aws_region: (Some(String::default())),
@@ -232,6 +225,6 @@ mod tests {
             }),
             response_elements: (HashMap::new()),
             s3: (s3_entity),
-        };
+        }
     }
 }
diff --git a/examples/basic-s3-thumbnail/src/s3.rs b/examples/basic-s3-thumbnail/src/s3.rs
index 0dd8629d..1a759371 100644
--- a/examples/basic-s3-thumbnail/src/s3.rs
+++ b/examples/basic-s3-thumbnail/src/s3.rs
@@ -1,7 +1,5 @@
 use async_trait::async_trait;
-use aws_sdk_s3::operation::get_object::GetObjectError;
-use aws_sdk_s3::Client as S3Client;
-use aws_smithy_http::byte_stream::ByteStream;
+use aws_sdk_s3::{operation::get_object::GetObjectError, primitives::ByteStream, Client as S3Client};
 use lambda_runtime::tracing;
 
 #[async_trait]
@@ -45,7 +43,7 @@ impl PutFile for S3Client {
         let result = self.put_object().bucket(bucket).key(key).body(bytes).send().await;
 
         match result {
-            Ok(_) => Ok(format!("Uploaded a file with key {} into {}", key, bucket)),
+            Ok(_) => Ok(format!("Uploaded a file with key {key} into {bucket}")),
             Err(err) => Err(err.into_service_error().meta().message().unwrap().to_string()),
         }
     }
diff --git a/examples/basic-sdk/Cargo.toml b/examples/basic-sdk/Cargo.toml
index 454a970f..6e680aaf 100644
--- a/examples/basic-sdk/Cargo.toml
+++ b/examples/basic-sdk/Cargo.toml
@@ -7,12 +7,11 @@ edition = "2021"
 
 [dependencies]
 async-trait = "0.1"
-aws-config = "0.54"
-aws-sdk-s3 = "0.24"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-sdk-s3 = "1.96.0"
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.136"
+serde = "1.0.219"
 tokio = { version = "1", features = ["macros"] }
 
 [dev-dependencies]
-mockall = "0.11.3"
-tokio-test = "0.4.2"
\ No newline at end of file
+mockall = "0.13.1"
diff --git a/examples/basic-sdk/src/main.rs b/examples/basic-sdk/src/main.rs
index d49c84e1..a021f4c2 100644
--- a/examples/basic-sdk/src/main.rs
+++ b/examples/basic-sdk/src/main.rs
@@ -1,5 +1,5 @@
 use async_trait::async_trait;
-use aws_sdk_s3::{output::ListObjectsV2Output, Client as S3Client};
+use aws_sdk_s3::{operation::list_objects_v2::ListObjectsV2Output, Client as S3Client};
 use lambda_runtime::{service_fn, tracing, Error, LambdaEvent};
 use serde::{Deserialize, Serialize};
 
@@ -52,8 +52,7 @@ async fn my_handler<T: ListObjects>(event: LambdaEvent<Request>, client: &T) ->
     let objects_rsp = client.list_objects(&bucket).await?;
     let objects: Vec<_> = objects_rsp
         .contents()
-        .ok_or("missing objects in list-objects-v2 response")?
-        .into_iter()
+        .iter()
         .filter_map(|o| o.key().map(|k| k.to_string()))
         .collect();
 
@@ -71,7 +70,7 @@ async fn my_handler<T: ListObjects>(event: LambdaEvent<Request>, client: &T) ->
 #[cfg(test)]
 mod tests {
     use super::*;
-    use aws_sdk_s3::model::Object;
+    use aws_sdk_s3::types::Object;
     use lambda_runtime::{Context, LambdaEvent};
     use mockall::predicate::eq;
 
diff --git a/examples/basic-shared-resource/Cargo.toml b/examples/basic-shared-resource/Cargo.toml
index 2aad5886..514bef32 100644
--- a/examples/basic-shared-resource/Cargo.toml
+++ b/examples/basic-shared-resource/Cargo.toml
@@ -5,5 +5,5 @@ edition = "2021"
 
 [dependencies]
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.136"
+serde = "1.0.219"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/basic-sqs/Cargo.toml b/examples/basic-sqs/Cargo.toml
index 0df7d8e2..36efee36 100644
--- a/examples/basic-sqs/Cargo.toml
+++ b/examples/basic-sqs/Cargo.toml
@@ -17,5 +17,5 @@ edition = "2021"
 [dependencies]
 aws_lambda_events = { path = "../../lambda-events" }
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.136"
+serde = "1.0.219"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/basic-streaming-response/src/main.rs b/examples/basic-streaming-response/src/main.rs
index 8533c8e3..fe112b80 100644
--- a/examples/basic-streaming-response/src/main.rs
+++ b/examples/basic-streaming-response/src/main.rs
@@ -7,7 +7,7 @@ use serde_json::Value;
 use std::{thread, time::Duration};
 
 async fn func(_event: LambdaEvent<Value>) -> Result<Response<Body>, Error> {
-    let messages = vec!["Hello", "world", "from", "Lambda!"];
+    let messages = ["Hello", "world", "from", "Lambda!"];
 
     let (mut tx, rx) = channel();
 
diff --git a/examples/extension-basic/Cargo.toml b/examples/extension-basic/Cargo.toml
index 48e2ed51..d7cf1f13 100644
--- a/examples/extension-basic/Cargo.toml
+++ b/examples/extension-basic/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/extension-combined/Cargo.toml b/examples/extension-combined/Cargo.toml
index 2a745c7b..93aacca1 100644
--- a/examples/extension-combined/Cargo.toml
+++ b/examples/extension-combined/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/extension-custom-events/Cargo.toml b/examples/extension-custom-events/Cargo.toml
index c2f813c3..dfef4c4b 100644
--- a/examples/extension-custom-events/Cargo.toml
+++ b/examples/extension-custom-events/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/extension-custom-service/Cargo.toml b/examples/extension-custom-service/Cargo.toml
index b51eae8e..8d0e4575 100644
--- a/examples/extension-custom-service/Cargo.toml
+++ b/examples/extension-custom-service/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/extension-internal-flush/Cargo.toml b/examples/extension-internal-flush/Cargo.toml
index 70e27ebf..1a0747dd 100644
--- a/examples/extension-internal-flush/Cargo.toml
+++ b/examples/extension-internal-flush/Cargo.toml
@@ -8,5 +8,5 @@ anyhow = "1"
 aws_lambda_events = { path = "../../lambda-events" }
 lambda-extension = { path = "../../lambda-extension" }
 lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.136"
+serde = "1.0.219"
 tokio = { version = "1.46", features = ["macros", "sync"] }
diff --git a/examples/extension-internal-flush/src/main.rs b/examples/extension-internal-flush/src/main.rs
index 9a515ff8..d20213e1 100644
--- a/examples/extension-internal-flush/src/main.rs
+++ b/examples/extension-internal-flush/src/main.rs
@@ -2,8 +2,10 @@ use anyhow::anyhow;
 use aws_lambda_events::sqs::{SqsBatchResponse, SqsEventObj};
 use lambda_extension::{service_fn, tracing, Error, Extension, NextEvent};
 use serde::{Deserialize, Serialize};
-use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
-use tokio::sync::Mutex;
+use tokio::sync::{
+    mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender},
+    Mutex,
+};
 
 use std::sync::Arc;
 
diff --git a/examples/extension-logs-basic/Cargo.toml b/examples/extension-logs-basic/Cargo.toml
index dccc1ec0..230ebc7e 100644
--- a/examples/extension-logs-basic/Cargo.toml
+++ b/examples/extension-logs-basic/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros", "rt"] }
diff --git a/examples/extension-logs-custom-service/Cargo.toml b/examples/extension-logs-custom-service/Cargo.toml
index 1b1eea0a..421fe9ff 100644
--- a/examples/extension-logs-custom-service/Cargo.toml
+++ b/examples/extension-logs-custom-service/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/extension-logs-kinesis-firehose/Cargo.toml b/examples/extension-logs-kinesis-firehose/Cargo.toml
index c6675e5a..84f7ac96 100644
--- a/examples/extension-logs-kinesis-firehose/Cargo.toml
+++ b/examples/extension-logs-kinesis-firehose/Cargo.toml
@@ -5,6 +5,6 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-tokio = { version = "1.17.0", features = ["full"] }
-aws-config = "0.13.0"
-aws-sdk-firehose = "0.13.0"
+tokio = { version = "1.46.1", features = ["full"] }
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-sdk-firehose = "1.82.0"
diff --git a/examples/extension-logs-kinesis-firehose/src/main.rs b/examples/extension-logs-kinesis-firehose/src/main.rs
index 7871ce52..c9d8a2e4 100644
--- a/examples/extension-logs-kinesis-firehose/src/main.rs
+++ b/examples/extension-logs-kinesis-firehose/src/main.rs
@@ -1,4 +1,4 @@
-use aws_sdk_firehose::{model::Record, types::Blob, Client};
+use aws_sdk_firehose::{primitives::Blob, types::Record, Client};
 use lambda_extension::{tracing, Error, Extension, LambdaLog, LambdaLogRecord, Service, SharedService};
 use std::{future::Future, pin::Pin, task::Poll};
 
@@ -31,7 +31,12 @@ impl Service<Vec<LambdaLog>> for FirehoseLogsProcessor {
         for log in logs {
             match log.record {
                 LambdaLogRecord::Function(record) => {
-                    records.push(Record::builder().data(Blob::new(record.as_bytes())).build())
+                    match Record::builder().data(Blob::new(record.as_bytes())).build() {
+                        Ok(rec) => records.push(rec),
+                        Err(e) => {
+                            return Box::pin(async move { Err(e.into()) });
+                        }
+                    }
                 }
                 _ => unreachable!(),
             }
diff --git a/examples/extension-telemetry-basic/Cargo.toml b/examples/extension-telemetry-basic/Cargo.toml
index 1b8b1ba4..a0fb6b87 100644
--- a/examples/extension-telemetry-basic/Cargo.toml
+++ b/examples/extension-telemetry-basic/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda-extension = { path = "../../lambda-extension" }
-serde = "1.0.136"
 tokio = { version = "1", features = ["macros", "rt"] }
diff --git a/examples/http-axum-apigw-authorizer/Cargo.toml b/examples/http-axum-apigw-authorizer/Cargo.toml
index c757aa94..44c50167 100644
--- a/examples/http-axum-apigw-authorizer/Cargo.toml
+++ b/examples/http-axum-apigw-authorizer/Cargo.toml
@@ -4,9 +4,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-axum = "0.7"
+axum = "0.8"
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.196"
 serde_json = "1.0"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-axum-apigw-authorizer/src/main.rs b/examples/http-axum-apigw-authorizer/src/main.rs
index 513a6cd8..8adb9024 100644
--- a/examples/http-axum-apigw-authorizer/src/main.rs
+++ b/examples/http-axum-apigw-authorizer/src/main.rs
@@ -1,5 +1,4 @@
 use axum::{
-    async_trait,
     extract::{FromRequest, Request},
     http::StatusCode,
     response::Json,
@@ -13,7 +12,6 @@ use std::{collections::HashMap, env::set_var};
 struct AuthorizerField(String);
 struct AuthorizerFields(HashMap<String, serde_json::Value>);
 
-#[async_trait]
 impl<S> FromRequest<S> for AuthorizerField
 where
     S: Send + Sync,
@@ -30,7 +28,6 @@ where
     }
 }
 
-#[async_trait]
 impl<S> FromRequest<S> for AuthorizerFields
 where
     S: Send + Sync,
diff --git a/examples/http-axum-diesel-ssl/Cargo.toml b/examples/http-axum-diesel-ssl/Cargo.toml
index 69366957..d21df0b9 100755
--- a/examples/http-axum-diesel-ssl/Cargo.toml
+++ b/examples/http-axum-diesel-ssl/Cargo.toml
@@ -4,16 +4,14 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-axum = "0.7"
-bb8 = "0.8.0"
-diesel = "2.0.3"
-diesel-async = { version = "0.2.1", features = ["postgres", "bb8"] }
+axum = "0.8"
+diesel = "2.2.11"
+diesel-async = { version = "0.6.1", features = ["postgres", "bb8"] }
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.159"
-futures-util = "0.3.21"
-rustls = "0.20.8"
-rustls-native-certs = "0.6.2"
-tokio = { version = "1.2.0", default-features = false, features = ["macros", "rt-multi-thread"] }
-tokio-postgres = "0.7.7"
-tokio-postgres-rustls = "0.9.0"
\ No newline at end of file
+serde = "1.0.219"
+futures-util = "0.3.31"
+rustls = "0.23.28"
+rustls-native-certs = "0.8.1"
+tokio = { version = "1.46.1", default-features = false, features = ["macros", "rt-multi-thread"] }
+tokio-postgres = "0.7.13"
+tokio-postgres-rustls = "0.13.0"
diff --git a/examples/http-axum-diesel-ssl/src/main.rs b/examples/http-axum-diesel-ssl/src/main.rs
index b340b44d..395c1843 100755
--- a/examples/http-axum-diesel-ssl/src/main.rs
+++ b/examples/http-axum-diesel-ssl/src/main.rs
@@ -1,19 +1,18 @@
-use diesel::{ConnectionError, ConnectionResult};
-use futures_util::future::BoxFuture;
-use futures_util::FutureExt;
-use std::time::Duration;
-
 use axum::{
     extract::{Path, State},
     response::Json,
     routing::get,
     Router,
 };
-use bb8::Pool;
-use diesel::prelude::*;
-use diesel_async::{pooled_connection::AsyncDieselConnectionManager, AsyncPgConnection, RunQueryDsl};
+use diesel::{prelude::*, ConnectionError, ConnectionResult};
+use diesel_async::{
+    pooled_connection::{bb8::Pool, AsyncDieselConnectionManager, ManagerConfig},
+    AsyncPgConnection, RunQueryDsl,
+};
+use futures_util::{future::BoxFuture, FutureExt};
 use lambda_http::{http::StatusCode, run, tracing, Error};
 use serde::{Deserialize, Serialize};
+use std::time::Duration;
 
 table! {
     posts (id) {
@@ -40,7 +39,7 @@ struct NewPost {
     published: bool,
 }
 
-type AsyncPool = Pool<AsyncDieselConnectionManager<AsyncPgConnection>>;
+type AsyncPool = Pool<AsyncPgConnection>;
 type ServerError = (StatusCode, String);
 
 async fn create_post(State(pool): State<AsyncPool>, Json(post): Json<NewPost>) -> Result<Json<Post>, ServerError> {
@@ -104,7 +103,10 @@ async fn main() -> Result<(), Error> {
     // Format for DATABASE_URL=postgres://your_username:your_password@your_host:5432/your_db?sslmode=require
     let db_url = std::env::var("DATABASE_URL").expect("Env var `DATABASE_URL` not set");
 
-    let mgr = AsyncDieselConnectionManager::<AsyncPgConnection>::new_with_setup(db_url, establish_connection);
+    let mut config = ManagerConfig::default();
+    config.custom_setup = Box::new(establish_connection);
+
+    let mgr = AsyncDieselConnectionManager::<AsyncPgConnection>::new_with_config(db_url, config);
 
     let pool = Pool::builder()
         .max_size(10)
@@ -129,19 +131,15 @@ fn establish_connection(config: &str) -> BoxFuture<ConnectionResult<AsyncPgConne
     let fut = async {
         // We first set up the way we want rustls to work.
         let rustls_config = rustls::ClientConfig::builder()
-            .with_safe_defaults()
             .with_root_certificates(root_certs())
             .with_no_client_auth();
+
         let tls = tokio_postgres_rustls::MakeRustlsConnect::new(rustls_config);
         let (client, conn) = tokio_postgres::connect(config, tls)
             .await
             .map_err(|e| ConnectionError::BadConnection(e.to_string()))?;
-        tokio::spawn(async move {
-            if let Err(e) = conn.await {
-                eprintln!("Database connection: {e}");
-            }
-        });
-        AsyncPgConnection::try_from(client).await
+
+        AsyncPgConnection::try_from_client_and_connection(client, conn).await
     };
     fut.boxed()
 }
@@ -149,7 +147,6 @@ fn establish_connection(config: &str) -> BoxFuture<ConnectionResult<AsyncPgConne
 fn root_certs() -> rustls::RootCertStore {
     let mut roots = rustls::RootCertStore::empty();
     let certs = rustls_native_certs::load_native_certs().expect("Certs not loadable!");
-    let certs: Vec<_> = certs.into_iter().map(|cert| cert.0).collect();
-    roots.add_parsable_certificates(&certs);
+    roots.add_parsable_certificates(certs);
     roots
 }
diff --git a/examples/http-axum-diesel/Cargo.toml b/examples/http-axum-diesel/Cargo.toml
index 39fc813e..bed36762 100644
--- a/examples/http-axum-diesel/Cargo.toml
+++ b/examples/http-axum-diesel/Cargo.toml
@@ -4,11 +4,9 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-axum = "0.7"
-bb8 = "0.8.0"
-diesel = "2.0.3"
-diesel-async = { version = "0.2.1", features = ["postgres", "bb8"] }
+axum = "0.8"
+diesel = "2.2.11"
+diesel-async = { version = "0.6.1", features = ["postgres", "bb8"] }
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.159"
+serde = "1.0.219"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-axum-diesel/src/main.rs b/examples/http-axum-diesel/src/main.rs
index b7247be4..348d7535 100644
--- a/examples/http-axum-diesel/src/main.rs
+++ b/examples/http-axum-diesel/src/main.rs
@@ -4,9 +4,11 @@ use axum::{
     routing::get,
     Router,
 };
-use bb8::Pool;
 use diesel::prelude::*;
-use diesel_async::{pooled_connection::AsyncDieselConnectionManager, AsyncPgConnection, RunQueryDsl};
+use diesel_async::{
+    pooled_connection::{bb8::Pool, AsyncDieselConnectionManager},
+    AsyncPgConnection, RunQueryDsl,
+};
 use lambda_http::{http::StatusCode, run, tracing, Error};
 use serde::{Deserialize, Serialize};
 
@@ -35,7 +37,7 @@ struct NewPost {
     published: bool,
 }
 
-type AsyncPool = Pool<AsyncDieselConnectionManager<AsyncPgConnection>>;
+type AsyncPool = Pool<AsyncPgConnection>;
 type ServerError = (StatusCode, String);
 
 async fn create_post(State(pool): State<AsyncPool>, Json(post): Json<NewPost>) -> Result<Json<Post>, ServerError> {
diff --git a/examples/http-axum-middleware/Cargo.toml b/examples/http-axum-middleware/Cargo.toml
index 228fc0ae..f3966941 100644
--- a/examples/http-axum-middleware/Cargo.toml
+++ b/examples/http-axum-middleware/Cargo.toml
@@ -4,10 +4,9 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-axum = "0.7"
+axum = "0.8"
 lambda_http = { path = "../../lambda-http", default-features = false, features = [
   "apigw_rest", "tracing"
 ] }
-lambda_runtime = { path = "../../lambda-runtime" }
 serde_json = "1.0"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-axum-middleware/src/main.rs b/examples/http-axum-middleware/src/main.rs
index b1e92811..e335c270 100644
--- a/examples/http-axum-middleware/src/main.rs
+++ b/examples/http-axum-middleware/src/main.rs
@@ -10,8 +10,7 @@
 //! ```
 
 use axum::{response::Json, routing::post, Router};
-use lambda_http::request::RequestContext::ApiGatewayV1;
-use lambda_http::{run, tracing, Error};
+use lambda_http::{request::RequestContext::ApiGatewayV1, run, tracing, Error};
 use serde_json::{json, Value};
 
 // Sample middleware that logs the request id
diff --git a/examples/http-axum/Cargo.toml b/examples/http-axum/Cargo.toml
index 7ab3c0ec..7664e7a7 100644
--- a/examples/http-axum/Cargo.toml
+++ b/examples/http-axum/Cargo.toml
@@ -4,9 +4,8 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-axum = "0.7"
+axum = "0.8"
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
-serde = "1.0.196"
+serde = "1.0.219"
 serde_json = "1.0"
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-axum/src/main.rs b/examples/http-axum/src/main.rs
index dcd5d154..3b00fc57 100644
--- a/examples/http-axum/src/main.rs
+++ b/examples/http-axum/src/main.rs
@@ -6,10 +6,9 @@
 //! implementation to the Lambda runtime to run as a Lambda function.  By using Axum instead
 //! of a basic `tower::Service` you get web framework niceties like routing, request component
 //! extraction, validation, etc.
-use axum::extract::Query;
-use axum::http::StatusCode;
 use axum::{
-    extract::Path,
+    extract::{Path, Query},
+    http::StatusCode,
     response::Json,
     routing::{get, post},
     Router,
diff --git a/examples/http-basic-lambda/Cargo.toml b/examples/http-basic-lambda/Cargo.toml
index c7a51507..2f252389 100644
--- a/examples/http-basic-lambda/Cargo.toml
+++ b/examples/http-basic-lambda/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-cors/Cargo.toml b/examples/http-cors/Cargo.toml
index b8e51031..b9c9efa5 100644
--- a/examples/http-cors/Cargo.toml
+++ b/examples/http-cors/Cargo.toml
@@ -5,6 +5,5 @@ edition = "2021"
 
 [dependencies]
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
 tokio = { version = "1", features = ["macros"] }
-tower-http = { version = "0.5", features = ["cors"] }
+tower-http = { version = "0.6", features = ["cors"] }
diff --git a/examples/http-cors/src/main.rs b/examples/http-cors/src/main.rs
index ffac0a9e..4c2c54b4 100644
--- a/examples/http-cors/src/main.rs
+++ b/examples/http-cors/src/main.rs
@@ -28,7 +28,7 @@ async fn func(event: Request) -> Result<Response<Body>, Error> {
             .query_string_parameters_ref()
             .and_then(|params| params.first("first_name"))
         {
-            Some(first_name) => format!("Hello, {}!", first_name).into_response().await,
+            Some(first_name) => format!("Hello, {first_name}!").into_response().await,
             None => Response::builder()
                 .status(400)
                 .body("Empty first name".into())
diff --git a/examples/http-dynamodb/Cargo.toml b/examples/http-dynamodb/Cargo.toml
index f2b8db98..d347c346 100644
--- a/examples/http-dynamodb/Cargo.toml
+++ b/examples/http-dynamodb/Cargo.toml
@@ -4,11 +4,10 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-simple-error = "0.3.0"
-serde_json = "1.0.107"
-serde = { version = "1.0.189", features = ["derive"] }
-serde_dynamo = {version = "^4.2.7", features = ["aws-sdk-dynamodb+0_33"]}
+serde_json = "1.0.140"
+serde = { version = "1.0.219", features = ["derive"] }
+serde_dynamo = { version = "4.2.14", features = ["aws-sdk-dynamodb+1"] }
 lambda_http = { path = "../../lambda-http" }
-aws-sdk-dynamodb = "0.33.0"
-aws-config = "0.56.1"
-tokio = { version = "1.33.0", features = ["macros"] }
+aws-sdk-dynamodb = "1.82.0"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+tokio = { version = "1.46.1", features = ["macros"] }
diff --git a/examples/http-dynamodb/src/main.rs b/examples/http-dynamodb/src/main.rs
index 2bf3fb9d..0d37693f 100644
--- a/examples/http-dynamodb/src/main.rs
+++ b/examples/http-dynamodb/src/main.rs
@@ -1,15 +1,15 @@
 use aws_sdk_dynamodb::Client;
 use lambda_http::{run, service_fn, tracing, Body, Error, Request, Response};
 use serde::{Deserialize, Serialize};
-use serde_dynamo::to_attribute_value;
+use serde_dynamo::to_item;
 
 #[derive(Clone, Debug, Serialize, Deserialize)]
 pub struct Item {
-    pub p_type: String,
+    pub account_type: String,
     pub age: String,
     pub username: String,
-    pub first: String,
-    pub last: String,
+    pub first_name: String,
+    pub last_name: String,
 }
 
 /// This is the main body for the function.
@@ -71,20 +71,9 @@ async fn main() -> Result<(), Error> {
 // Add an item to a table.
 // snippet-start:[dynamodb.rust.add-item]
 pub async fn add_item(client: &Client, item: Item, table: &str) -> Result<(), Error> {
-    let user_av = to_attribute_value(item.username)?;
-    let type_av = to_attribute_value(item.p_type)?;
-    let age_av = to_attribute_value(item.age)?;
-    let first_av = to_attribute_value(item.first)?;
-    let last_av = to_attribute_value(item.last)?;
+    let item = to_item(item)?;
 
-    let request = client
-        .put_item()
-        .table_name(table)
-        .item("username", user_av)
-        .item("account_type", type_av)
-        .item("age", age_av)
-        .item("first_name", first_av)
-        .item("last_name", last_av);
+    let request = client.put_item().table_name(table).set_item(Some(item));
 
     tracing::info!("adding item to DynamoDB");
 
diff --git a/examples/http-query-parameters/Cargo.toml b/examples/http-query-parameters/Cargo.toml
index 2cadda95..18f8e6cf 100644
--- a/examples/http-query-parameters/Cargo.toml
+++ b/examples/http-query-parameters/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-query-parameters/src/main.rs b/examples/http-query-parameters/src/main.rs
index ef9cf658..c974e633 100644
--- a/examples/http-query-parameters/src/main.rs
+++ b/examples/http-query-parameters/src/main.rs
@@ -11,7 +11,7 @@ async fn function_handler(event: Request) -> Result<impl IntoResponse, Error> {
             .query_string_parameters_ref()
             .and_then(|params| params.first("first_name"))
         {
-            Some(first_name) => format!("Hello, {}!", first_name).into_response().await,
+            Some(first_name) => format!("Hello, {first_name}!").into_response().await,
             None => Response::builder()
                 .status(400)
                 .body("Empty first name".into())
diff --git a/examples/http-raw-path/Cargo.toml b/examples/http-raw-path/Cargo.toml
index f6c56526..d1c5ccb8 100644
--- a/examples/http-raw-path/Cargo.toml
+++ b/examples/http-raw-path/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-shared-resource/Cargo.toml b/examples/http-shared-resource/Cargo.toml
index 923ceecc..8f5a0e94 100644
--- a/examples/http-shared-resource/Cargo.toml
+++ b/examples/http-shared-resource/Cargo.toml
@@ -5,5 +5,4 @@ edition = "2021"
 
 [dependencies]
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = { path = "../../lambda-runtime" }
 tokio = { version = "1", features = ["macros"] }
diff --git a/examples/http-tower-trace/Cargo.toml b/examples/http-tower-trace/Cargo.toml
index 36389f0e..cf1f223b 100644
--- a/examples/http-tower-trace/Cargo.toml
+++ b/examples/http-tower-trace/Cargo.toml
@@ -5,6 +5,5 @@ edition = "2021"
 
 [dependencies]
 lambda_http = { path = "../../lambda-http" }
-lambda_runtime = "0.5.1"
 tokio = { version = "1", features = ["macros"] }
-tower-http = { version = "0.5", features = ["trace"] }
+tower-http = { version = "0.6", features = ["trace"] }
diff --git a/examples/http-tower-trace/src/main.rs b/examples/http-tower-trace/src/main.rs
index df2b9007..7dd0c1d6 100644
--- a/examples/http-tower-trace/src/main.rs
+++ b/examples/http-tower-trace/src/main.rs
@@ -1,6 +1,9 @@
-use lambda_http::tracing::{self, Level};
-use lambda_http::{run, tower::ServiceBuilder, Error};
-use lambda_http::{Request, Response};
+use lambda_http::{
+    run,
+    tower::ServiceBuilder,
+    tracing::{self, Level},
+    Error, Request, Response,
+};
 use tower_http::trace::{DefaultOnRequest, DefaultOnResponse, TraceLayer};
 
 async fn handler(_req: Request) -> Result<Response<String>, Error> {
diff --git a/examples/lambda-rds-iam-auth/Cargo.toml b/examples/lambda-rds-iam-auth/Cargo.toml
index a1e212ae..68b0fe92 100644
--- a/examples/lambda-rds-iam-auth/Cargo.toml
+++ b/examples/lambda-rds-iam-auth/Cargo.toml
@@ -5,10 +5,10 @@ edition = "2021"
 
 [dependencies]
 lambda_runtime = { path = "../../lambda-runtime" }
-serde_json = "1.0.120"
-aws-config = "1.0.1"
-aws-credential-types = "1.0.1"
-aws-sigv4 = "1.0.1"
-url = "2.5.0"
-tokio = { version = "1.25.0", features = ["full"] }
-sqlx = { version = "0.7.4", features = ["tls-rustls", "postgres", "runtime-tokio"] }
+serde_json = "1.0.140"
+aws-config = { version = "1.8.1", features = ["behavior-version-latest"] }
+aws-credential-types = "1.2.3"
+aws-sigv4 = "1.3.3"
+url = "2.5.4"
+tokio = { version = "1.46.1", features = ["full"] }
+sqlx = { version = "0.8.6", features = ["tls-rustls", "postgres", "runtime-tokio"] }
diff --git a/examples/lambda-rds-iam-auth/src/main.rs b/examples/lambda-rds-iam-auth/src/main.rs
index 32cf3580..fbf8394f 100644
--- a/examples/lambda-rds-iam-auth/src/main.rs
+++ b/examples/lambda-rds-iam-auth/src/main.rs
@@ -7,17 +7,15 @@ use aws_sigv4::{
 use lambda_runtime::{run, service_fn, Error, LambdaEvent};
 use serde_json::{json, Value};
 use sqlx::postgres::PgConnectOptions;
-use std::env;
-use std::time::{Duration, SystemTime};
+use std::{
+    env,
+    time::{Duration, SystemTime},
+};
 
 const RDS_CERTS: &[u8] = include_bytes!("global-bundle.pem");
 
-async fn generate_rds_iam_token(
-    db_hostname: &str,
-    port: u16,
-    db_username: &str,
-) -> Result<String, Error> {
-    let config = aws_config::load_defaults(BehaviorVersion::v2024_03_28()).await;
+async fn generate_rds_iam_token(db_hostname: &str, port: u16, db_username: &str) -> Result<String, Error> {
+    let config = aws_config::load_defaults(BehaviorVersion::latest()).await;
 
     let credentials = config
         .credentials_provider()
@@ -40,23 +38,16 @@ async fn generate_rds_iam_token(
         .settings(signing_settings)
         .build()?;
 
-    let url = format!(
-        "https://{db_hostname}:{port}/?Action=connect&DBUser={db_user}",
-        db_hostname = db_hostname,
-        port = port,
-        db_user = db_username
-    );
+    let url = format!("https://{db_hostname}:{port}/?Action=connect&DBUser={db_username}");
 
     let signable_request =
-        SignableRequest::new("GET", &url, std::iter::empty(), SignableBody::Bytes(&[]))
-            .expect("signable request");
+        SignableRequest::new("GET", &url, std::iter::empty(), SignableBody::Bytes(&[])).expect("signable request");
 
-    let (signing_instructions, _signature) =
-        sign(signable_request, &signing_params.into())?.into_parts();
+    let (signing_instructions, _signature) = sign(signable_request, &signing_params.into())?.into_parts();
 
     let mut url = url::Url::parse(&url).unwrap();
     for (name, value) in signing_instructions.params() {
-        url.query_pairs_mut().append_pair(name, &value);
+        url.query_pairs_mut().append_pair(name, value);
     }
 
     let response = url.to_string().split_off("https://".len());
@@ -89,9 +80,7 @@ async fn handler(_event: LambdaEvent<Value>) -> Result<Value, Error> {
         .ssl_root_cert_from_pem(RDS_CERTS.to_vec())
         .ssl_mode(sqlx::postgres::PgSslMode::Require);
 
-    let pool = sqlx::postgres::PgPoolOptions::new()
-        .connect_with(opts)
-        .await?;
+    let pool = sqlx::postgres::PgPoolOptions::new().connect_with(opts).await?;
 
     let result: i32 = sqlx::query_scalar("SELECT $1 + $2")
         .bind(3)
@@ -99,7 +88,7 @@ async fn handler(_event: LambdaEvent<Value>) -> Result<Value, Error> {
         .fetch_one(&pool)
         .await?;
 
-    println!("Result: {:?}", result);
+    println!("Result: {result:?}");
 
     Ok(json!({
         "statusCode": 200,
diff --git a/examples/opentelemetry-tracing/Cargo.toml b/examples/opentelemetry-tracing/Cargo.toml
index 98108d39..c9b2a9cb 100644
--- a/examples/opentelemetry-tracing/Cargo.toml
+++ b/examples/opentelemetry-tracing/Cargo.toml
@@ -5,14 +5,12 @@ edition = "2021"
 
 [dependencies]
 lambda_runtime = { path = "../../lambda-runtime", features = ["opentelemetry"] }
-opentelemetry-semantic-conventions = "0.14"
-opentelemetry = "0.22"
-opentelemetry_sdk = { version = "0.22", features = ["rt-tokio"] }
-opentelemetry-stdout = { version = "0.3", features = ["trace"] }
-pin-project = "1"
+opentelemetry = "0.30"
+opentelemetry_sdk = { version = "0.30", features = ["rt-tokio"] }
+opentelemetry-stdout = { version = "0.30", features = ["trace"] }
 serde_json = "1.0"
 tokio = "1"
 tower = "0.5"
 tracing = "0.1"
-tracing-opentelemetry = "0.23"
+tracing-opentelemetry = "0.31"
 tracing-subscriber = "0.3"
diff --git a/examples/opentelemetry-tracing/src/main.rs b/examples/opentelemetry-tracing/src/main.rs
index 062f5a11..a75aa016 100644
--- a/examples/opentelemetry-tracing/src/main.rs
+++ b/examples/opentelemetry-tracing/src/main.rs
@@ -4,7 +4,7 @@ use lambda_runtime::{
     LambdaEvent, Runtime,
 };
 use opentelemetry::trace::TracerProvider;
-use opentelemetry_sdk::{runtime, trace};
+use opentelemetry_sdk::trace;
 use tower::{service_fn, BoxError};
 use tracing_subscriber::prelude::*;
 
@@ -18,8 +18,8 @@ async fn echo(event: LambdaEvent<serde_json::Value>) -> Result<serde_json::Value
 async fn main() -> Result<(), BoxError> {
     // Set up OpenTelemetry tracer provider that writes spans to stdout for debugging purposes
     let exporter = opentelemetry_stdout::SpanExporter::default();
-    let tracer_provider = trace::TracerProvider::builder()
-        .with_batch_exporter(exporter, runtime::Tokio)
+    let tracer_provider = trace::SdkTracerProvider::builder()
+        .with_batch_exporter(exporter)
         .build();
 
     // Set up link between OpenTelemetry and tracing crate
@@ -34,7 +34,9 @@ async fn main() -> Result<(), BoxError> {
         // Create a tracing span for each Lambda invocation
         OtelLayer::new(|| {
             // Make sure that the trace is exported before the Lambda runtime is frozen
-            tracer_provider.force_flush();
+            if let Err(err) = tracer_provider.force_flush() {
+                eprintln!("Error flushing traces: {err:#?}");
+            }
         })
         // Set the "faas.trigger" attribute of the span to "pubsub"
         .with_trigger(OpenTelemetryFaasTrigger::PubSub),
diff --git a/lambda-extension/Cargo.toml b/lambda-extension/Cargo.toml
index 4754ffbe..d178520a 100644
--- a/lambda-extension/Cargo.toml
+++ b/lambda-extension/Cargo.toml
@@ -20,7 +20,6 @@ tracing = ["lambda_runtime_api_client/tracing"]
 
 [dependencies]
 async-stream = "0.3"
-bytes = { workspace = true }
 chrono = { workspace = true, features = ["serde"] }
 http = { workspace = true }
 http-body-util = { workspace = true }
diff --git a/lambda-http/Cargo.toml b/lambda-http/Cargo.toml
index 38b65a56..4498e275 100644
--- a/lambda-http/Cargo.toml
+++ b/lambda-http/Cargo.toml
@@ -30,10 +30,8 @@ eyre = ["lambda_runtime/eyre"] # enables From<T> for Diagnostic for eyre error t
 miette = ["lambda_runtime/miette"] # enables From<T> for Diagnostic for miette error types, see README.md for more info
 
 [dependencies]
-base64 = { workspace = true }
 bytes = { workspace = true }
 encoding_rs = "0.8"
-futures = { workspace = true }
 futures-util = { workspace = true }
 http = { workspace = true }
 http-body = { workspace = true }
@@ -56,8 +54,8 @@ default-features = false
 features = ["alb", "apigw"]
 
 [dev-dependencies]
-axum-core = "0.4.3"
-axum-extra = { version = "0.9.2", features = ["query"] }
+axum-core = "0.5.0"
+axum-extra = { version = "0.10.0", features = ["query"] }
 lambda_runtime_api_client = { version = "0.12.1", path = "../lambda-runtime-api-client" }
 log = "^0.4"
 maplit = "1.0"
diff --git a/lambda-integration-tests/Cargo.toml b/lambda-integration-tests/Cargo.toml
index f0bdb292..0a9836c4 100644
--- a/lambda-integration-tests/Cargo.toml
+++ b/lambda-integration-tests/Cargo.toml
@@ -20,7 +20,6 @@ serde = { version = "1.0.204", features = ["derive"] }
 
 [dev-dependencies]
 reqwest = { version = "0.12.5", features = ["blocking"] }
-openssl = { version = "0.10", features = ["vendored"] }
 
 [[bin]]
 name = "helloworld"
diff --git a/lambda-runtime-api-client/Cargo.toml b/lambda-runtime-api-client/Cargo.toml
index 640560e0..cc2289af 100644
--- a/lambda-runtime-api-client/Cargo.toml
+++ b/lambda-runtime-api-client/Cargo.toml
@@ -33,8 +33,6 @@ hyper-util = { workspace = true, features = [
     "tokio",
 ] }
 tower = { workspace = true, features = ["util"] }
-tower-service = { workspace = true }
-tokio = { version = "1.0", features = ["io-util"] }
 tracing = { version = "0.1", features = ["log"], optional = true }
 tracing-subscriber = { version = "0.3", default-features = false, features = ["fmt", "json", "env-filter"], optional = true }
 
diff --git a/lambda-runtime/Cargo.toml b/lambda-runtime/Cargo.toml
index c4787d56..6e0dde73 100644
--- a/lambda-runtime/Cargo.toml
+++ b/lambda-runtime/Cargo.toml
@@ -34,16 +34,9 @@ bytes = { workspace = true }
 eyre = { version = "0.6.12", optional = true }
 futures = { workspace = true }
 http = { workspace = true }
-http-body = { workspace = true }
 http-body-util = { workspace = true }
 http-serde = { workspace = true }
 hyper = { workspace = true, features = ["http1", "client"] }
-hyper-util = { workspace = true, features = [
-    "client",
-    "client-legacy",
-    "http1",
-    "tokio",
-] }
 lambda-extension = { version = "0.12.1", path = "../lambda-extension", default-features = false, optional = true }
 lambda_runtime_api_client = { version = "0.12.2", path = "../lambda-runtime-api-client", default-features = false }
 miette = { version = "7.2.0", optional = true }
@@ -60,7 +53,6 @@ tokio = { version = "1.46", features = [
 ] }
 tokio-stream = "0.1.2"
 tower = { workspace = true, features = ["util"] }
-tower-layer = { workspace = true }
 tracing = { version = "0.1", features = ["log"] }
 
 [dev-dependencies]