diff --git a/README.md b/README.md
index 13de5a2..0407d71 100644
--- a/README.md
+++ b/README.md
@@ -14,7 +14,7 @@ assumptions about a microservice:
     `write_file` function, and a database ORM `connection`.
 3. All microservices must communicate with the shared PostgreSQL database via
     an ORM connection passed into `process`.
-    - Rust microservices use `diesel::pg::PgConnection`.
+    - Rust microservices use `diesel::PgConnection`.
     - Python microservices use `sqlalchemy.engine.base.Connection`.
 3. The `process` function returns a set of IDs (also `u64`) that are the result
    of processing the incoming request.  Each of these IDs is also associated
@@ -134,7 +134,7 @@ Linux wheel covers all CPython versions ≥ 3.8.
 
 ```rust
 use slingshot_microservice::Microservice;
-use diesel::pg::PgConnection;
+use diesel::PgConnection;
 use slingshot_microservice::{AnyError, ReadFileFn, WriteFileFn};
 use std::io::{Read, Write};
 
@@ -235,7 +235,7 @@ Within each `process` pass:
     returns an opened local file handle for writing, staging the output for
     `s3://{resolved_bucket}/{id}`.
 3. `connection` is an ORM-backed PostgreSQL connection passed into `process`
-    (`diesel::pg::PgConnection` in Rust, `sqlalchemy.engine.base.Connection`
+    (`diesel::PgConnection` in Rust, `sqlalchemy.engine.base.Connection`
     in Python).
 4.  After `process` returns, opened files are closed.
 5.  Then staged write files are uploaded to S3 with the AWS SDK, local staged
diff --git a/examples/simple.rs b/examples/simple.rs
index ac1ccbb..5de7b2c 100644
--- a/examples/simple.rs
+++ b/examples/simple.rs
@@ -1,5 +1,5 @@
 use slingshot_microservice::{AnyError, Microservice, ReadFileFn, WriteFileFn};
-use diesel::pg::PgConnection;
+use diesel::PgConnection;
 use std::io::{Read, Write};
 
 fn process(
diff --git a/src/lib.rs b/src/lib.rs
index 637cb4a..cccc994 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -15,7 +15,7 @@ use aws_sdk_s3::Client;
 use aws_sdk_s3::config::{Credentials, Region};
 use aws_sdk_s3::primitives::ByteStream;
 use diesel::Connection as DieselConnection;
-use diesel::pg::PgConnection;
+use diesel::PgConnection;
 use futures_util::StreamExt;
 use lapin::options::{
 	BasicAckOptions, BasicConsumeOptions, BasicNackOptions, BasicPublishOptions,