From e2c8678855b75f60ca701c9a97b6aa33ae40280c Mon Sep 17 00:00:00 2001 From: Tom Moor Date: Tue, 19 Mar 2024 18:57:15 -0400 Subject: [PATCH] chore: Move some tasks to background priority --- server/queues/tasks/CleanupDemotedUserTask.ts | 8 +++++++- server/queues/tasks/DeleteAttachmentTask.ts | 8 +++++++- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/server/queues/tasks/CleanupDemotedUserTask.ts b/server/queues/tasks/CleanupDemotedUserTask.ts index 6ea96e14a..5fd16e843 100644 --- a/server/queues/tasks/CleanupDemotedUserTask.ts +++ b/server/queues/tasks/CleanupDemotedUserTask.ts @@ -1,7 +1,7 @@ import Logger from "@server/logging/Logger"; import { WebhookSubscription, ApiKey, User } from "@server/models"; import { sequelize } from "@server/storage/database"; -import BaseTask from "./BaseTask"; +import BaseTask, { TaskPriority } from "./BaseTask"; type Props = { userId: string; @@ -54,4 +54,10 @@ export default class CleanupDemotedUserTask extends BaseTask { } }); } + + public get options() { + return { + priority: TaskPriority.Background, + }; + } } diff --git a/server/queues/tasks/DeleteAttachmentTask.ts b/server/queues/tasks/DeleteAttachmentTask.ts index d770d671a..19fe72ffb 100644 --- a/server/queues/tasks/DeleteAttachmentTask.ts +++ b/server/queues/tasks/DeleteAttachmentTask.ts @@ -1,5 +1,5 @@ import { Attachment } from "@server/models"; -import BaseTask from "./BaseTask"; +import BaseTask, { TaskPriority } from "./BaseTask"; type Props = { teamId: string; @@ -21,4 +21,10 @@ export default class DeleteAttachmentTask extends BaseTask { await attachment.destroy(); } + + public get options() { + return { + priority: TaskPriority.Background, + }; + } }