fix: miss job names

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<void> {
     await this.dataSeedDemoWorkspaceService.seedDemo();
   }

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<void> {
     const dataSourceMetadata =
       await this.dataSourceService.getLastDataSourceMetadataFromWorkspaceIdOrFail(

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<void> {
     try {
       await this.httpService.axiosRef.post(data.targetUrl, data);

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<void> {
     this.recordPositionBackfillService.backfill(data.workspaceId, data.dryRun);
   }

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<void> {
     const workspaceMembersCount =
       await this.userWorkspaceService.getWorkspaceMemberCount(data.workspaceId);

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<void> {
     const { workspaceId, userId } = data;
 

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<void> {
     await this.emailSenderService.send(data);
   }

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<void> {
     const isDryRun = data.dryRun || false;
 

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<void> {
     const { workspaceId, email, personId, workspaceMemberId } = data;
 

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<void> {
     const { workspaceId, email, personId, workspaceMemberId } = data;
 

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<void> {
     const workspaceIds = (
       await this.workspaceRepository.find({

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<void> {
     const { workspaceId, blocklistItemId } = data;
 

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<void> {
     const { workspaceId, workspaceMemberId, handle } = data;
 

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<void> {

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<void> {

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<void> {
     this.logger.log(
       `google calendar sync for workspace ${data.workspaceId} and account ${data.connectedAccountId}`,

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<void> {
     const { workspaceId, connectedAccountHandle, contactsToCreate } = data;
 

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<void> {
     const { workspaceId, blocklistItemId } = data;
 

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<void> {
     const { workspaceId, workspaceMemberId, handle } = data;
 

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<void> {

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<void> {
     const workspaceIds = (
       await this.workspaceRepository.find({

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<void> {
     const workspaceIds = (
       await this.workspaceRepository.find({

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<void> {
     const { workspaceId, connectedAccountId } = data;
 

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<void> {
     const { workspaceId } = data;
 

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<FeatureFlagEntity>,
   ) {}
 
-  @Process()
+  @Process(MessagingCreateCompanyAndContactAfterSyncJob.name)
   async handle(
     data: MessagingCreateCompanyAndContactAfterSyncJobData,
   ): Promise<void> {

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<void> {
     let workspaceMemberId: string | null = null;
 

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<void> {
     if (data.userId) {
       const workspaceMember = await this.workspaceMemberService.getByIdOrFail(