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

Fix: Set sync stage started at when starting sync (#7046)

Browse Source 
Fix:`syncStageStartedAt` was not set correctly after refactoring
This commit is contained in:
Raphaël Bosi
2024-09-16 15:10:53 +02:00
committed by GitHub
parent 833832525c
commit f1264fda76
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/twenty-server/src/modules/messaging/common/services/message-channel-sync-status.service.ts
View File

@ -125,6 +125,7 @@ export class MessageChannelSyncStatusService {
await messageChannelRepository.update(messageChannelIds, { await messageChannelRepository.update(messageChannelIds, {
syncStage: MessageChannelSyncStage.MESSAGE_LIST_FETCH_ONGOING, syncStage: MessageChannelSyncStage.MESSAGE_LIST_FETCH_ONGOING,
syncStatus: MessageChannelSyncStatus.ONGOING, syncStatus: MessageChannelSyncStatus.ONGOING,
syncStageStartedAt: new Date().toISOString(),
}); });
} }
@ -142,9 +143,10 @@ export class MessageChannelSyncStatusService {
await messageChannelRepository.update(messageChannelIds, { await messageChannelRepository.update(messageChannelIds, {
syncStatus: MessageChannelSyncStatus.ACTIVE, syncStatus: MessageChannelSyncStatus.ACTIVE,
syncStage: MessageChannelSyncStage.PARTIAL_MESSAGE_LIST_FETCH_PENDING,
throttleFailureCount: 0,
syncStageStartedAt: null,
}); });
await this.schedulePartialMessageListFetch(messageChannelIds);
} }
public async markAsMessagesImportOngoing(messageChannelIds: string[]) { public async markAsMessagesImportOngoing(messageChannelIds: string[]) {