admin/twenty
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

add sentry monitoring + update cron pattern to each hour (#10583)

Browse Source 
Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>
This commit is contained in:
Etienne
2025-02-28 14:34:18 +01:00
committed by GitHub
parent 2aa72de210
commit 33370f5d1f
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/twenty-server/src/engine/workspace-manager/workspace-cleaner/crons/clean-suspended-workspaces.cron.pattern.ts
View File

@ -1 +1 @@
export const cleanSuspendedWorkspaceCronPattern = '0 22 * * *'; // Every day at 10pm
export const cleanSuspendedWorkspaceCronPattern = '0 * * * *'; // Every hour at minute 0

6
packages/twenty-server/src/engine/workspace-manager/workspace-cleaner/crons/clean-suspended-workspaces.job.ts
View File

@ -3,10 +3,12 @@ import { InjectRepository } from '@nestjs/typeorm';
import { WorkspaceActivationStatus } from 'twenty-shared';
import { Repository } from 'typeorm';
import { SentryCronMonitor } from 'src/engine/core-modules/cron/sentry-cron-monitor.decorator';
import { Process } from 'src/engine/core-modules/message-queue/decorators/process.decorator';
import { Processor } from 'src/engine/core-modules/message-queue/decorators/processor.decorator';
import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queue.constants';
import { Workspace } from 'src/engine/core-modules/workspace/workspace.entity';
import { cleanSuspendedWorkspaceCronPattern } from 'src/engine/workspace-manager/workspace-cleaner/crons/clean-suspended-workspaces.cron.pattern';
import { CleanerWorkspaceService } from 'src/engine/workspace-manager/workspace-cleaner/services/cleaner.workspace-service';
@Processor(MessageQueue.cronQueue)
@ -18,6 +20,10 @@ export class CleanSuspendedWorkspacesJob {
) {}
@Process(CleanSuspendedWorkspacesJob.name)
@SentryCronMonitor(
CleanSuspendedWorkspacesJob.name,
cleanSuspendedWorkspaceCronPattern,
)
async handle(): Promise<void> {
const suspendedWorkspaceIds = await this.workspaceRepository.find({
select: ['id'],