diff --git a/Sources/PostgresKit/Deprecations/PostgresColumnType.swift b/Sources/PostgresKit/Deprecations/PostgresColumnType.swift
index 88b352f..19f6f67 100644
--- a/Sources/PostgresKit/Deprecations/PostgresColumnType.swift
+++ b/Sources/PostgresKit/Deprecations/PostgresColumnType.swift
@@ -203,7 +203,7 @@ public struct PostgresColumnType: SQLExpression, Hashable {
     private let primitive: Primitive
     private init(_ primitive: Primitive) { self.primitive = primitive }
 
-    enum Primitive: CustomStringConvertible, Hashable {
+    enum Primitive: CustomStringConvertible, Hashable, Sendable {
         case bigint /// signed eight-byte integer
         case bigserial /// autoincrementing eight-byte integer
         case bit(Int?) /// fixed-length bit string
diff --git a/Sources/PostgresKit/PostgresDatabase+SQL.swift b/Sources/PostgresKit/PostgresDatabase+SQL.swift
index 0d2c070..dac3c40 100644
--- a/Sources/PostgresKit/PostgresDatabase+SQL.swift
+++ b/Sources/PostgresKit/PostgresDatabase+SQL.swift
@@ -109,7 +109,7 @@ extension _PostgresSQLDatabase: SQLDatabase, PostgresDatabase {
         self.database.withConnection(closure)
     }
     
-    func withSession<R>(_ closure: @escaping (any SQLDatabase) async throws -> R) async throws -> R {
+    func withSession<R>(_ closure: @escaping @Sendable (any SQLDatabase) async throws -> R) async throws -> R {
         try await self.withConnection { c in
             c.eventLoop.makeFutureWithTask {
                 try await closure(c.sql(