Max/zkldi_Tachi
1
0
Fork 0
mirror of https://github.com/zkldi/Tachi.git synced 2026-09-22 23:18:05 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix: better admin cron view (#1698)

Browse Source
This commit is contained in:
zk
2026-06-19 22:35:50 +01:00
committed by GitHub
parent 6ed20dfe26
commit 78e23ab7cd
1 changed files with 6 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
typescript/server/src/lib/admin/admin-queries.ts
+6 -30
View File
@@ -7,7 +7,6 @@ import {
SELECT_JOB_QUEUE,
} from "#lib/db-formats/admin-jobs";
import DB from "#services/pg/db";
import { sql } from "kysely";
export const ADMIN_PAGE_SIZE = 50;
@@ -162,34 +161,11 @@ export function GetCronTasks(): Promise<Array<CronTask>> {
.execute();
}
const CAP_PER_TASK_TYPE = 100;
export async function GetCronTaskExecutions(): Promise<Array<CronTaskExecution>> {
const rows = await DB.with("ranked", (db) =>
db
.selectFrom("cron_task_execution")
.select([
...SELECT_CRON_TASK_EXECUTION,
sql<number>`ROW_NUMBER() OVER (PARTITION BY cron_task_execution.task_id ORDER BY cron_task_execution.scheduled_at DESC)`.as(
"rn",
),
])
.where("cron_task_execution.scheduled_at", ">=", adminRecentSinceIso()),
)
.selectFrom("ranked")
.select([
"ranked.id",
"ranked.task_id",
"ranked.scheduled_at",
"ranked.started_at",
"ranked.completed_at",
"ranked.status",
"ranked.output",
"ranked.error",
])
.where(sql<boolean>`ranked.rn <= ${sql.lit(CAP_PER_TASK_TYPE)}`)
.orderBy("ranked.scheduled_at", "desc")
export function GetCronTaskExecutions(): Promise<Array<CronTaskExecution>> {
return DB.selectFrom("cron_task_execution")
.select(SELECT_CRON_TASK_EXECUTION)
.where("cron_task_execution.scheduled_at", ">=", adminRecentSinceIso(24 * 7))
.orderBy("cron_task_execution.scheduled_at", "desc")
.limit(100)
.execute();
return rows as Array<CronTaskExecution>;
}