mirror of
https://github.com/paperclipai/paperclip.git
synced 2026-11-11 05:11:49 +01:00
fix(memory-jobs): encode running lease filters
This commit is contained in:
1 parent
77a68dc059
commit
40dd54c96a
1 file changed
+5
-2
@@ -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));
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user