From 40dd54c96aa75d57588aa3c25c3d1cf6c6b7cff4 Mon Sep 17 00:00:00 2001
From: Dotta <bippadotta@protonmail.com>
Date: Tue, 21 Apr 2026 15:01:46 -0500
Subject: [PATCH] fix(memory-jobs): encode running lease filters

---
 server/src/services/memory-job-store.ts | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/server/src/services/memory-job-store.ts b/server/src/services/memory-job-store.ts
index ce9c8d68869..f3ad2c1dc2e 100644
--- a/server/src/services/memory-job-store.ts
+++ b/server/src/services/memory-job-store.ts
@@ -3,12 +3,12 @@ import {
   asc,
   desc,
   eq,
+  gt,
   gte,
   inArray,
   isNull,
   lte,
   or,
-  sql,
 } from "drizzle-orm";
 import type { Db } from "@paperclipai/db";
 import { memoryExtractionJobs } from "@paperclipai/db";
@@ -335,7 +335,10 @@ export function memoryJobStore(db: Db) {
       conditions.push(lte(memoryExtractionJobs.leaseExpiresAt, now));
     } else if (query.effectiveState === "running") {
       conditions.push(eq(memoryExtractionJobs.status, "running"));
-      conditions.push(sql`(${memoryExtractionJobs.leaseExpiresAt} is null or ${memoryExtractionJobs.leaseExpiresAt} > ${now})`);
+      conditions.push(or(
+        isNull(memoryExtractionJobs.leaseExpiresAt),
+        gt(memoryExtractionJobs.leaseExpiresAt, now),
+      )!);
     } else if (query.effectiveState) {
       conditions.push(eq(memoryExtractionJobs.status, query.effectiveState));
     }