Clean up

apps/api/src/app/app.module.ts

@@ -37,7 +37,12 @@ import { UserModule } from './user/user.module';
     AccountModule,
     AuthDeviceModule,
     AuthModule,
-    BullModule.forRoot({}),
+    BullModule.forRoot({
+      redis: {
+        host: process.env.REDIS_HOST,
+        port: parseInt(process.env.REDIS_PORT, 10)
+      }
+    }),
     CacheModule,
     ConfigModule.forRoot(),
     ConfigurationModule,

apps/api/src/services/cron.service.ts

@@ -39,6 +39,7 @@ export class CronService {
   @Cron(CronExpression.EVERY_WEEKEND)
   public async runEveryWeekend() {
     const uniqueAssets = await this.dataGatheringService.getUniqueAssets();
+
     for (const { dataSource, symbol } of uniqueAssets) {
       await this.dataGatheringQueue.add(GATHER_ASSET_PROFILE_PROCESS, {
         dataSource,

apps/api/src/services/data-gathering.service.ts

@@ -227,8 +227,6 @@ export class DataGatheringService {
   }
 
   public async gatherAssetProfiles(aUniqueAssets?: UniqueAsset[]) {
-    console.time('data-gathering-asset-profile');
-
     let uniqueAssets = aUniqueAssets?.filter((dataGatheringItem) => {
       return dataGatheringItem.dataSource !== 'MANUAL';
     });
@@ -325,10 +323,13 @@ export class DataGatheringService {
     }
 
     Logger.log(
-      'Asset profile data gathering has been completed.',
+      `Asset profile data gathering has been completed for ${uniqueAssets
+        .map(({ dataSource, symbol }) => {
+          return `${symbol} (${dataSource})`;
+        })
+        .join(',')}.`,
       'DataGatheringService'
     );
-    console.timeEnd('data-gathering-asset-profile');
   }
 
   public async gatherSymbols(aSymbolsWithStartDate: IDataGatheringItem[]) {