diff --git a/apps/api/src/services/queues/data-gathering/data-gathering.service.ts b/apps/api/src/services/queues/data-gathering/data-gathering.service.ts index c433f692f..f82325f0c 100644 --- a/apps/api/src/services/queues/data-gathering/data-gathering.service.ts +++ b/apps/api/src/services/queues/data-gathering/data-gathering.service.ts @@ -307,23 +307,19 @@ export class DataGatheringService { const symbolProfiles = await this.prismaService.symbolProfile.findMany({ orderBy: [{ symbol: 'asc' }], where: { + dataSource: { + notIn: ['MANUAL', 'RAPID_API'] + }, isActive: true } }); - return symbolProfiles - .filter(({ dataSource }) => { - return ( - dataSource !== DataSource.MANUAL && - dataSource !== DataSource.RAPID_API - ); - }) - .map(({ dataSource, symbol }) => { - return { - dataSource, - symbol - }; - }); + return symbolProfiles.map(({ dataSource, symbol }) => { + return { + dataSource, + symbol + }; + }); } private async getAssetProfileIdentifiersWithCompleteMarketData(): Promise<