diff --git a/crates/torii/libp2p/src/server/mod.rs b/crates/torii/libp2p/src/server/mod.rs
index 85b81ade16..95216e8e18 100644
--- a/crates/torii/libp2p/src/server/mod.rs
+++ b/crates/torii/libp2p/src/server/mod.rs
@@ -252,10 +252,8 @@ impl<P: Provider + Sync> Relay<P> {
                             let model_id = ty_model_id(&ty).unwrap();
 
                             // select only identity field, if doesn't exist, empty string
-                            let query = format!(
-                                "SELECT external_identity FROM [{}] WHERE id = ?",
-                                ty.name()
-                            );
+                            let query =
+                                format!("SELECT identity FROM [{}] WHERE id = ?", ty.name());
                             let entity_identity: Option<String> = match sqlx::query_scalar(&query)
                                 .bind(format!("{:#x}", entity_id))
                                 .fetch_optional(&mut *pool)