From 2cf34b43e46d7627f579422d456eee71605c7727 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A9r=C3=A9my=20Magrin?= Date: Thu, 6 Jun 2024 14:49:05 +0200 Subject: [PATCH] fix: miss job names --- .../jobs/data-seed-demo-workspace.job.ts | 2 +- .../workspace-query-runner/jobs/call-webhook-jobs.job.ts | 2 +- .../api/graphql/workspace-query-runner/jobs/call-webhook.job.ts | 2 +- .../workspace-query-runner/jobs/record-position-backfill.job.ts | 2 +- .../engine/core-modules/billing/jobs/update-subscription.job.ts | 2 +- .../workspace/handle-workspace-member-deleted.job.ts | 2 +- .../src/engine/integrations/email/email-sender.job.ts | 2 +- .../workspace-cleaner/crons/clean-inactive-workspace.job.ts | 2 +- .../jobs/match-participant.job.ts | 2 +- .../jobs/unmatch-participant.job.ts | 2 +- .../calendar/crons/jobs/google-calendar-sync.cron.job.ts | 2 +- .../calendar/jobs/blocklist-item-delete-calendar-events.job.ts | 2 +- .../calendar/jobs/blocklist-reimport-calendar-events.job.ts | 2 +- .../jobs/calendar-create-company-and-contact-after-sync.job.ts | 2 +- .../delete-connected-account-associated-calendar-data.job.ts | 2 +- .../src/modules/calendar/jobs/google-calendar-sync.job.ts | 2 +- .../jobs/create-company-and-contact.job.ts | 2 +- .../jobs/messaging-blocklist-item-delete-messages.job.ts | 2 +- .../jobs/messaging-blocklist-reimport-messages.job.ts | 2 +- .../jobs/messaging-connected-account-deletion-cleanup.job.ts | 2 +- .../crons/jobs/messaging-message-list-fetch.cron.job.ts | 2 +- .../crons/jobs/messaging-messages-import.cron.job.ts | 2 +- .../jobs/messaging-message-list-fetch.job.ts | 2 +- .../jobs/messaging-messages-import.job.ts | 2 +- .../jobs/messaging-create-company-and-contact-after-sync.job.ts | 2 +- .../timeline/jobs/create-audit-log-from-internal-event.ts | 2 +- .../jobs/upsert-timeline-activity-from-internal-event.job.ts | 2 +- 27 files changed, 27 insertions(+), 27 deletions(-) diff --git a/packages/twenty-server/src/database/commands/data-seed-demo-workspace/jobs/data-seed-demo-workspace.job.ts b/packages/twenty-server/src/database/commands/data-seed-demo-workspace/jobs/data-seed-demo-workspace.job.ts index fbf4b462b9e81..14655209c009d 100644 --- a/packages/twenty-server/src/database/commands/data-seed-demo-workspace/jobs/data-seed-demo-workspace.job.ts +++ b/packages/twenty-server/src/database/commands/data-seed-demo-workspace/jobs/data-seed-demo-workspace.job.ts @@ -9,7 +9,7 @@ export class DataSeedDemoWorkspaceJob { private readonly dataSeedDemoWorkspaceService: DataSeedDemoWorkspaceService, ) {} - @Process() + @Process(DataSeedDemoWorkspaceJob.name) async handle(): Promise { await this.dataSeedDemoWorkspaceService.seedDemo(); } diff --git a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook-jobs.job.ts b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook-jobs.job.ts index e5ae6a0b8651d..818be2a60d657 100644 --- a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook-jobs.job.ts +++ b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook-jobs.job.ts @@ -38,7 +38,7 @@ export class CallWebhookJobsJob { private readonly messageQueueService: MessageQueueService, ) {} - @Process() + @Process(CallWebhookJobsJob.name) async handle(data: CallWebhookJobsJobData): Promise { const dataSourceMetadata = await this.dataSourceService.getLastDataSourceMetadataFromWorkspaceIdOrFail( diff --git a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook.job.ts b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook.job.ts index 0f27d98272ae6..d18686e96abae 100644 --- a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook.job.ts +++ b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/call-webhook.job.ts @@ -21,7 +21,7 @@ export class CallWebhookJob { constructor(private readonly httpService: HttpService) {} - @Process() + @Process(CallWebhookJob.name) async handle(data: CallWebhookJobData): Promise { try { await this.httpService.axiosRef.post(data.targetUrl, data); diff --git a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/record-position-backfill.job.ts b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/record-position-backfill.job.ts index 57cb737eaa8a9..8619f11828140 100644 --- a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/record-position-backfill.job.ts +++ b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/jobs/record-position-backfill.job.ts @@ -14,7 +14,7 @@ export class RecordPositionBackfillJob { private readonly recordPositionBackfillService: RecordPositionBackfillService, ) {} - @Process() + @Process(RecordPositionBackfillJob.name) async handle(data: RecordPositionBackfillJobData): Promise { this.recordPositionBackfillService.backfill(data.workspaceId, data.dryRun); } diff --git a/packages/twenty-server/src/engine/core-modules/billing/jobs/update-subscription.job.ts b/packages/twenty-server/src/engine/core-modules/billing/jobs/update-subscription.job.ts index 30907e3d918e6..33f690fdddbe0 100644 --- a/packages/twenty-server/src/engine/core-modules/billing/jobs/update-subscription.job.ts +++ b/packages/twenty-server/src/engine/core-modules/billing/jobs/update-subscription.job.ts @@ -18,7 +18,7 @@ export class UpdateSubscriptionJob { private readonly stripeService: StripeService, ) {} - @Process() + @Process(UpdateSubscriptionJob.name) async handle(data: UpdateSubscriptionJobData): Promise { const workspaceMembersCount = await this.userWorkspaceService.getWorkspaceMemberCount(data.workspaceId); diff --git a/packages/twenty-server/src/engine/core-modules/workspace/handle-workspace-member-deleted.job.ts b/packages/twenty-server/src/engine/core-modules/workspace/handle-workspace-member-deleted.job.ts index 240f9a27b3b3d..7e3bce067751e 100644 --- a/packages/twenty-server/src/engine/core-modules/workspace/handle-workspace-member-deleted.job.ts +++ b/packages/twenty-server/src/engine/core-modules/workspace/handle-workspace-member-deleted.job.ts @@ -12,7 +12,7 @@ export type HandleWorkspaceMemberDeletedJobData = { export class HandleWorkspaceMemberDeletedJob { constructor(private readonly workspaceService: WorkspaceService) {} - @Process() + @Process(HandleWorkspaceMemberDeletedJob.name) async handle(data: HandleWorkspaceMemberDeletedJobData): Promise { const { workspaceId, userId } = data; diff --git a/packages/twenty-server/src/engine/integrations/email/email-sender.job.ts b/packages/twenty-server/src/engine/integrations/email/email-sender.job.ts index 29089809d4882..d97117d5063c8 100644 --- a/packages/twenty-server/src/engine/integrations/email/email-sender.job.ts +++ b/packages/twenty-server/src/engine/integrations/email/email-sender.job.ts @@ -9,7 +9,7 @@ import { Process } from 'src/engine/integrations/message-queue/decorators/proces export class EmailSenderJob { constructor(private readonly emailSenderService: EmailSenderService) {} - @Process() + @Process(EmailSenderJob.name) async handle(data: SendMailOptions): Promise { await this.emailSenderService.send(data); } diff --git a/packages/twenty-server/src/engine/workspace-manager/workspace-cleaner/crons/clean-inactive-workspace.job.ts b/packages/twenty-server/src/engine/workspace-manager/workspace-cleaner/crons/clean-inactive-workspace.job.ts index 9e9d7ffb0023d..95f9fc9a4f174 100644 --- a/packages/twenty-server/src/engine/workspace-manager/workspace-cleaner/crons/clean-inactive-workspace.job.ts +++ b/packages/twenty-server/src/engine/workspace-manager/workspace-cleaner/crons/clean-inactive-workspace.job.ts @@ -192,7 +192,7 @@ export class CleanInactiveWorkspaceJob { }); } - @Process() + @Process(CleanInactiveWorkspaceJob.name) async handle(data: CleanInactiveWorkspacesCommandOptions): Promise { const isDryRun = data.dryRun || false; diff --git a/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/match-participant.job.ts b/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/match-participant.job.ts index 87ecc6050791e..97f639e8d7a23 100644 --- a/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/match-participant.job.ts +++ b/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/match-participant.job.ts @@ -18,7 +18,7 @@ export class MatchParticipantJob { private readonly calendarEventParticipantService: CalendarEventParticipantService, ) {} - @Process() + @Process(MatchParticipantJob.name) async handle(data: MatchParticipantJobData): Promise { const { workspaceId, email, personId, workspaceMemberId } = data; diff --git a/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/unmatch-participant.job.ts b/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/unmatch-participant.job.ts index 3b4dbc46545c0..34b0e06f31ef7 100644 --- a/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/unmatch-participant.job.ts +++ b/packages/twenty-server/src/modules/calendar-messaging-participant/jobs/unmatch-participant.job.ts @@ -18,7 +18,7 @@ export class UnmatchParticipantJob { private readonly calendarEventParticipantService: CalendarEventParticipantService, ) {} - @Process() + @Process(UnmatchParticipantJob.name) async handle(data: UnmatchParticipantJobData): Promise { const { workspaceId, email, personId, workspaceMemberId } = data; diff --git a/packages/twenty-server/src/modules/calendar/crons/jobs/google-calendar-sync.cron.job.ts b/packages/twenty-server/src/modules/calendar/crons/jobs/google-calendar-sync.cron.job.ts index 5b146bd7c2b08..f9b39cfaba8d9 100644 --- a/packages/twenty-server/src/modules/calendar/crons/jobs/google-calendar-sync.cron.job.ts +++ b/packages/twenty-server/src/modules/calendar/crons/jobs/google-calendar-sync.cron.job.ts @@ -21,7 +21,7 @@ export class GoogleCalendarSyncCronJob { private readonly environmentService: EnvironmentService, ) {} - @Process() + @Process(GoogleCalendarSyncCronJob.name) async handle(): Promise { const workspaceIds = ( await this.workspaceRepository.find({ diff --git a/packages/twenty-server/src/modules/calendar/jobs/blocklist-item-delete-calendar-events.job.ts b/packages/twenty-server/src/modules/calendar/jobs/blocklist-item-delete-calendar-events.job.ts index d05db3d541d14..5b9b9ddc9d7c7 100644 --- a/packages/twenty-server/src/modules/calendar/jobs/blocklist-item-delete-calendar-events.job.ts +++ b/packages/twenty-server/src/modules/calendar/jobs/blocklist-item-delete-calendar-events.job.ts @@ -35,7 +35,7 @@ export class BlocklistItemDeleteCalendarEventsJob { private readonly calendarEventCleanerService: CalendarEventCleanerService, ) {} - @Process() + @Process(BlocklistItemDeleteCalendarEventsJob.name) async handle(data: BlocklistItemDeleteCalendarEventsJobData): Promise { const { workspaceId, blocklistItemId } = data; diff --git a/packages/twenty-server/src/modules/calendar/jobs/blocklist-reimport-calendar-events.job.ts b/packages/twenty-server/src/modules/calendar/jobs/blocklist-reimport-calendar-events.job.ts index c311383d7404e..73069a36a88bf 100644 --- a/packages/twenty-server/src/modules/calendar/jobs/blocklist-reimport-calendar-events.job.ts +++ b/packages/twenty-server/src/modules/calendar/jobs/blocklist-reimport-calendar-events.job.ts @@ -24,7 +24,7 @@ export class BlocklistReimportCalendarEventsJob { private readonly googleCalendarSyncService: GoogleCalendarSyncService, ) {} - @Process() + @Process(BlocklistReimportCalendarEventsJob.name) async handle(data: BlocklistReimportCalendarEventsJobData): Promise { const { workspaceId, workspaceMemberId, handle } = data; diff --git a/packages/twenty-server/src/modules/calendar/jobs/calendar-create-company-and-contact-after-sync.job.ts b/packages/twenty-server/src/modules/calendar/jobs/calendar-create-company-and-contact-after-sync.job.ts index c1cdf334c718f..ad7da4528d91f 100644 --- a/packages/twenty-server/src/modules/calendar/jobs/calendar-create-company-and-contact-after-sync.job.ts +++ b/packages/twenty-server/src/modules/calendar/jobs/calendar-create-company-and-contact-after-sync.job.ts @@ -28,7 +28,7 @@ export class CalendarCreateCompanyAndContactAfterSyncJob { private readonly calendarEventParticipantRepository: CalendarEventParticipantRepository, ) {} - @Process() + @Process(CalendarCreateCompanyAndContactAfterSyncJob.name) async handle( data: CalendarCreateCompanyAndContactAfterSyncJobData, ): Promise { diff --git a/packages/twenty-server/src/modules/calendar/jobs/delete-connected-account-associated-calendar-data.job.ts b/packages/twenty-server/src/modules/calendar/jobs/delete-connected-account-associated-calendar-data.job.ts index fbb65f9a28f8d..bd8e5ab9e2c7e 100644 --- a/packages/twenty-server/src/modules/calendar/jobs/delete-connected-account-associated-calendar-data.job.ts +++ b/packages/twenty-server/src/modules/calendar/jobs/delete-connected-account-associated-calendar-data.job.ts @@ -20,7 +20,7 @@ export class DeleteConnectedAccountAssociatedCalendarDataJob { private readonly calendarEventCleanerService: CalendarEventCleanerService, ) {} - @Process() + @Process(DeleteConnectedAccountAssociatedCalendarDataJob.name) async handle( data: DeleteConnectedAccountAssociatedCalendarDataJobData, ): Promise { diff --git a/packages/twenty-server/src/modules/calendar/jobs/google-calendar-sync.job.ts b/packages/twenty-server/src/modules/calendar/jobs/google-calendar-sync.job.ts index bc6e5b7ff7d34..46240cca07629 100644 --- a/packages/twenty-server/src/modules/calendar/jobs/google-calendar-sync.job.ts +++ b/packages/twenty-server/src/modules/calendar/jobs/google-calendar-sync.job.ts @@ -20,7 +20,7 @@ export class GoogleCalendarSyncJob { private readonly googleCalendarSyncService: GoogleCalendarSyncService, ) {} - @Process() + @Process(GoogleCalendarSyncJob.name) async handle(data: GoogleCalendarSyncJobData): Promise { this.logger.log( `google calendar sync for workspace ${data.workspaceId} and account ${data.connectedAccountId}`, diff --git a/packages/twenty-server/src/modules/connected-account/auto-companies-and-contacts-creation/jobs/create-company-and-contact.job.ts b/packages/twenty-server/src/modules/connected-account/auto-companies-and-contacts-creation/jobs/create-company-and-contact.job.ts index 851b717131c9b..d46e70e4577e2 100644 --- a/packages/twenty-server/src/modules/connected-account/auto-companies-and-contacts-creation/jobs/create-company-and-contact.job.ts +++ b/packages/twenty-server/src/modules/connected-account/auto-companies-and-contacts-creation/jobs/create-company-and-contact.job.ts @@ -18,7 +18,7 @@ export class CreateCompanyAndContactJob { private readonly createCompanyAndContactService: CreateCompanyAndContactService, ) {} - @Process() + @Process(CreateCompanyAndContactJob.name) async handle(data: CreateCompanyAndContactJobData): Promise { const { workspaceId, connectedAccountHandle, contactsToCreate } = data; diff --git a/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-item-delete-messages.job.ts b/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-item-delete-messages.job.ts index 301b483b3411a..9e3aff8cd72c3 100644 --- a/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-item-delete-messages.job.ts +++ b/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-item-delete-messages.job.ts @@ -33,7 +33,7 @@ export class BlocklistItemDeleteMessagesJob { private readonly threadCleanerService: MessagingMessageCleanerService, ) {} - @Process() + @Process(BlocklistItemDeleteMessagesJob.name) async handle(data: BlocklistItemDeleteMessagesJobData): Promise { const { workspaceId, blocklistItemId } = data; diff --git a/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-reimport-messages.job.ts b/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-reimport-messages.job.ts index dc27c425e2321..47c2b93c0c1c6 100644 --- a/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-reimport-messages.job.ts +++ b/packages/twenty-server/src/modules/messaging/blocklist-manager/jobs/messaging-blocklist-reimport-messages.job.ts @@ -22,7 +22,7 @@ export class BlocklistReimportMessagesJob { private readonly connectedAccountRepository: ConnectedAccountRepository, ) {} - @Process() + @Process(BlocklistReimportMessagesJob.name) async handle(data: BlocklistReimportMessagesJobData): Promise { const { workspaceId, workspaceMemberId, handle } = data; diff --git a/packages/twenty-server/src/modules/messaging/message-cleaner/jobs/messaging-connected-account-deletion-cleanup.job.ts b/packages/twenty-server/src/modules/messaging/message-cleaner/jobs/messaging-connected-account-deletion-cleanup.job.ts index c4655cd992532..fbeb4f88a615f 100644 --- a/packages/twenty-server/src/modules/messaging/message-cleaner/jobs/messaging-connected-account-deletion-cleanup.job.ts +++ b/packages/twenty-server/src/modules/messaging/message-cleaner/jobs/messaging-connected-account-deletion-cleanup.job.ts @@ -20,7 +20,7 @@ export class MessagingConnectedAccountDeletionCleanupJob { private readonly messageCleanerService: MessagingMessageCleanerService, ) {} - @Process() + @Process(MessagingConnectedAccountDeletionCleanupJob.name) async handle( data: MessagingConnectedAccountDeletionCleanupJobData, ): Promise { diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-message-list-fetch.cron.job.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-message-list-fetch.cron.job.ts index f91cc8457d18c..5e3590a6e9a0d 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-message-list-fetch.cron.job.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-message-list-fetch.cron.job.ts @@ -35,7 +35,7 @@ export class MessagingMessageListFetchCronJob { private readonly environmentService: EnvironmentService, ) {} - @Process() + @Process(MessagingMessageListFetchCronJob.name) async handle(): Promise { const workspaceIds = ( await this.workspaceRepository.find({ diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-messages-import.cron.job.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-messages-import.cron.job.ts index 6f6e7c1ff7d34..a0c2048a7d0ba 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-messages-import.cron.job.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/crons/jobs/messaging-messages-import.cron.job.ts @@ -30,7 +30,7 @@ export class MessagingMessagesImportCronJob { private readonly messageQueueService: MessageQueueService, ) {} - @Process() + @Process(MessagingMessagesImportCronJob.name) async handle(): Promise { const workspaceIds = ( await this.workspaceRepository.find({ diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-message-list-fetch.job.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-message-list-fetch.job.ts index 87b740a36a79e..380daec02bcc9 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-message-list-fetch.job.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-message-list-fetch.job.ts @@ -35,7 +35,7 @@ export class MessagingMessageListFetchJob { private readonly messagingTelemetryService: MessagingTelemetryService, ) {} - @Process() + @Process(MessagingMessageListFetchJob.name) async handle(data: MessagingMessageListFetchJobData): Promise { const { workspaceId, connectedAccountId } = data; diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-messages-import.job.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-messages-import.job.ts index c69028e6d23e3..27b05d5a14e1a 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-messages-import.job.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/jobs/messaging-messages-import.job.ts @@ -25,7 +25,7 @@ export class MessagingMessagesImportJob { private readonly messagingTelemetryService: MessagingTelemetryService, ) {} - @Process() + @Process(MessagingMessagesImportJob.name) async handle(data: MessagingMessagesImportJobData): Promise { const { workspaceId } = data; diff --git a/packages/twenty-server/src/modules/messaging/message-participants-manager/jobs/messaging-create-company-and-contact-after-sync.job.ts b/packages/twenty-server/src/modules/messaging/message-participants-manager/jobs/messaging-create-company-and-contact-after-sync.job.ts index 5898336d25526..019238345815a 100644 --- a/packages/twenty-server/src/modules/messaging/message-participants-manager/jobs/messaging-create-company-and-contact-after-sync.job.ts +++ b/packages/twenty-server/src/modules/messaging/message-participants-manager/jobs/messaging-create-company-and-contact-after-sync.job.ts @@ -37,7 +37,7 @@ export class MessagingCreateCompanyAndContactAfterSyncJob { private readonly featureFlagRepository: Repository, ) {} - @Process() + @Process(MessagingCreateCompanyAndContactAfterSyncJob.name) async handle( data: MessagingCreateCompanyAndContactAfterSyncJobData, ): Promise { diff --git a/packages/twenty-server/src/modules/timeline/jobs/create-audit-log-from-internal-event.ts b/packages/twenty-server/src/modules/timeline/jobs/create-audit-log-from-internal-event.ts index 1112c9ea76d09..edf4c3d9e488f 100644 --- a/packages/twenty-server/src/modules/timeline/jobs/create-audit-log-from-internal-event.ts +++ b/packages/twenty-server/src/modules/timeline/jobs/create-audit-log-from-internal-event.ts @@ -17,7 +17,7 @@ export class CreateAuditLogFromInternalEvent { private readonly auditLogRepository: AuditLogRepository, ) {} - @Process() + @Process(CreateAuditLogFromInternalEvent.name) async handle(data: ObjectRecordBaseEvent): Promise { let workspaceMemberId: string | null = null; diff --git a/packages/twenty-server/src/modules/timeline/jobs/upsert-timeline-activity-from-internal-event.job.ts b/packages/twenty-server/src/modules/timeline/jobs/upsert-timeline-activity-from-internal-event.job.ts index f3746c81e6fcf..5abcb2e10da68 100644 --- a/packages/twenty-server/src/modules/timeline/jobs/upsert-timeline-activity-from-internal-event.job.ts +++ b/packages/twenty-server/src/modules/timeline/jobs/upsert-timeline-activity-from-internal-event.job.ts @@ -15,7 +15,7 @@ export class UpsertTimelineActivityFromInternalEvent { private readonly timelineActivityService: TimelineActivityService, ) {} - @Process() + @Process(UpsertTimelineActivityFromInternalEvent.name) async handle(data: ObjectRecordBaseEvent): Promise { if (data.userId) { const workspaceMember = await this.workspaceMemberService.getByIdOrFail(