diff --git a/src/worker/mod.rs b/src/worker/mod.rs
index 8ff0602..e83ba06 100644
--- a/src/worker/mod.rs
+++ b/src/worker/mod.rs
@@ -180,7 +180,7 @@ async fn process_task(state: &AppState, task_id: Uuid) -> Result<(), AppError> {
           session_id,
           api_key_id,
           source::text AS source,
-          client_ip::text AS client_ip
+          host(client_ip) AS client_ip
         FROM tasks
         WHERE id = $1
         "#,