hunk.code_window:     await workflowQueueService.work(delayedJob);
       const jobs = await jobRepository.find({
         _templateId: template._id,
       });
       const digestjobs = jobs.find((item) => item.digest.events.length > 0);
       await workflowQueueService.work(digestjobs);
       const messages = await messageRepository.find({
         _environmentId: session.environment._id,
         _subscriberId: subscriber._id,
         channel: ChannelTypeEnum.SMS,
  
hunk.labels: keep replace replace replace replace replace replace keep keep keep keep keep
hunk.after_edit:     for (const job of delayedJobs) {
         await workflowQueueService.work(job);
       }
       await awaitRunningJobs(0);
  
hunk.file_path: apps/api/src/app/events/e2e/digest-events.e2e.ts
hunk.type: replace
file: {
    "extends": "@nrwl/workspace/presets/npm.json",
    "npmScope": "novuhq",
    "tasksRunnerOptions": {
      "default": {
        "runner": "@nrwl/nx-cloud",
        "options": {
          "cacheableOperations": [
            "build",
            "test",
            "lint",
            "package",
            "prepare"
          ],
          "canTrackAnalytics": false,
          "accessToken": "N2EyNDhhMGUtYmJkNS00YzQ5LTg5NDYtODg5ZmE2NDE5YWNmfHJlYWQtd3JpdGU="
        }
      }
    },
    "targetDependencies": {
      "build": [
        {
          "target": "build",
          "projects": "dependencies"
        }
      ],
      "prepare": [
        {
          "target": "prepare",
          "projects": "dependencies"
        }
      ],
      "package": [
        {
          "target": "package",
          "projects": "dependencies"
        }
      ]
    },
    "affected": {
      "defaultBase": "main"
    }
  }
  