From 94872414817bc3bdd4c728668603cf1d67f7aab3 Mon Sep 17 00:00:00 2001
From: Mert <101130780+mertalev@users.noreply.github.com>
Date: Thu, 28 Aug 2025 20:23:40 -0400
Subject: [PATCH] fix(server): refresh faces query (#21380)

---
 server/src/queries/asset.job.repository.sql     | 3 +--
 server/src/repositories/asset-job.repository.ts | 4 ++--
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/server/src/queries/asset.job.repository.sql b/server/src/queries/asset.job.repository.sql
index df8163be3e..ef1b5fe79e 100644
--- a/server/src/queries/asset.job.repository.sql
+++ b/server/src/queries/asset.job.repository.sql
@@ -468,9 +468,8 @@ where
   "asset"."visibility" != $1
   and "asset"."deletedAt" is null
   and "job_status"."previewAt" is not null
-  and "job_status"."facesRecognizedAt" is null
 order by
-  "asset"."createdAt" desc
+  "asset"."fileCreatedAt" desc
 
 -- AssetJobRepository.streamForMigrationJob
 select
diff --git a/server/src/repositories/asset-job.repository.ts b/server/src/repositories/asset-job.repository.ts
index 0500bb867f..f7715b027c 100644
--- a/server/src/repositories/asset-job.repository.ts
+++ b/server/src/repositories/asset-job.repository.ts
@@ -334,9 +334,9 @@ export class AssetJobRepository {
   @GenerateSql({ params: [], stream: true })
   streamForDetectFacesJob(force?: boolean) {
     return this.assetsWithPreviews()
-      .$if(!force, (qb) => qb.where('job_status.facesRecognizedAt', 'is', null))
+      .$if(force === false, (qb) => qb.where('job_status.facesRecognizedAt', 'is', null))
       .select(['asset.id'])
-      .orderBy('asset.createdAt', 'desc')
+      .orderBy('asset.fileCreatedAt', 'desc')
       .stream();
   }