diff --git a/supabase/functions/migrate-novu-users/index.ts b/supabase/functions/migrate-novu-users/index.ts
index 6cedf1d9..b07a3ddd 100644
--- a/supabase/functions/migrate-novu-users/index.ts
+++ b/supabase/functions/migrate-novu-users/index.ts
@@ -38,10 +38,10 @@ serve(async (req) => {
 
     const existingUserIds = existingPrefs?.map(p => p.user_id) || [];
 
-    // Fetch all profiles
+    // Fetch all profiles with usernames
     let query = supabase
       .from('profiles')
-      .select('user_id');
+      .select('user_id, username');
 
     // Only add the not filter if there are existing user IDs
     if (existingUserIds.length > 0) {
@@ -96,6 +96,7 @@ serve(async (req) => {
       try {
         const subscriber = await novu.subscribers.identify(profile.user_id, {
           email,
+          firstName: profile.username,
           data: { userId: profile.user_id },
         });
 
@@ -110,6 +111,7 @@ serve(async (req) => {
         results.push({
           userId: profile.user_id,
           email,
+          username: profile.username,
           success: true,
         });
       } catch (error: any) {