diff --git a/packages/common/universalpubsub/src/driver/postgres/mod.rs b/packages/common/universalpubsub/src/driver/postgres/mod.rs
index 3115a7ac72..ddd845a878 100644
--- a/packages/common/universalpubsub/src/driver/postgres/mod.rs
+++ b/packages/common/universalpubsub/src/driver/postgres/mod.rs
@@ -1,6 +1,6 @@
 use std::collections::HashMap;
 use std::hash::{DefaultHasher, Hash, Hasher};
-use std::sync::Arc;
+use std::sync::{Arc, Mutex};
 
 use anyhow::*;
 use async_trait::async_trait;