diff --git a/src/lib/db/event-store.ts b/src/lib/db/event-store.ts index ae51d52677..37c303be1b 100644 --- a/src/lib/db/event-store.ts +++ b/src/lib/db/event-store.ts @@ -2,6 +2,8 @@ import { IEvent, IBaseEvent, SEGMENT_UPDATED, + FEATURE_IMPORT, + FEATURES_IMPORTED, IEventType, } from '../types/events'; import { LogProvider, Logger } from '../logger'; @@ -158,7 +160,11 @@ class EventStore implements IEventStore { .where((builder) => builder .whereNotNull('feature_name') - .orWhere('type', SEGMENT_UPDATED), + .orWhereIn('type', [ + SEGMENT_UPDATED, + FEATURE_IMPORT, + FEATURES_IMPORTED, + ]), ) .andWhere('id', '>=', largerThan) .first();