Merge pull request #297 from dhanush-2397/dev

Dynamic cron expression created for data pull for all storage types
Sunbird-cQube · Jan 31, 2024 · d8608c1 · d8608c1
2 parents 89a4ea7 + c734532
commit d8608c1
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/ingestion/services/nvsk-api/processorGroup.service.ts b/src/ingestion/services/nvsk-api/processorGroup.service.ts
@@ -7,9 +7,9 @@ export class processorGroupSelectionForCloudService {
 
   }
   getProcessorGroupArrayForCloudStorage() {
+    const currentDate:Date = this.dateService.getCurrentISTTime()
+    const cronExpr = this.dateService.getCronExpression(currentDate);
     if (process.env.STORAGE_TYPE === "oracle") {
-      const currentDate:Date = this.dateService.getCurrentISTTime()
-      const cronExpr = this.dateService.getCronExpression(currentDate);
       return [
         { processor_group_name: "Run_adapters", scheduled_at: "0 */7 * * * ?" },
         {
@@ -22,23 +22,23 @@ export class processorGroupSelectionForCloudService {
         { processor_group_name: "Run_adapters", scheduled_at: "0 */7 * * * ?" },
         {
           processor_group_name: "onestep_dataingestion_local",
-          scheduled_at: "0 */9 * * * ?",
+          scheduled_at: `${cronExpr}`,
         },
       ];
     } else if (process.env.STORAGE_TYPE === "aws") {
       return [
         { processor_group_name: "Run_adapters", scheduled_at: "0 */7 * * * ?" },
         {
           processor_group_name: "onestep_dataingestion_aws",
-          scheduled_at: "0 */9 * * * ?",
+          scheduled_at: `${cronExpr}`,
         },
       ];
     } else {
       return [
         { processor_group_name: "Run_adapters", scheduled_at: "0 */7 * * * ?" },
         {
           processor_group_name: "onestep_dataingestion_azure",
-          scheduled_at: "0 */9 * * * ?",
+          scheduled_at: `${cronExpr}`,
         },
       ];
     }