queue next job on bulk export job finish

apps/app/src/features/page-bulk-export/server/service/page-bulk-export/index.ts

@@ -434,7 +434,7 @@ class PageBulkExportService implements IPageBulkExportService {
    * - abort multipart upload
    */
   async cleanUpExportJobResources(pageBulkExportJob: PageBulkExportJobDocument, restarted = false) {
-    this.pageBulkExportJobManager.removeJobInProgress(pageBulkExportJob._id, restarted);
+    this.pageBulkExportJobManager.removeJobInProgressAndQueueNextJob(pageBulkExportJob._id, restarted);
 
     const promises = [
       PageBulkExportPageSnapshot.deleteMany({ pageBulkExportJob }),

apps/app/src/features/page-bulk-export/server/service/page-bulk-export/page-bulk-export-job-manager.ts

@@ -73,11 +73,13 @@ export class PageBulkExportJobManager {
   removeJobInProgressAndQueueNextJob(jobId: ObjectIdLike, isJobRestarted = false): void {
     this.removeJobInProgress(jobId, isJobRestarted);
 
-    if (this.jobQueue.length > 0 && this.canExecuteNextJob()) {
-      const nextJob = this.jobQueue.shift();
-      if (nextJob != null) {
-        this.jobsInProgress[nextJob.id.toString()] = { stream: undefined };
-        this.pageBulkExportService.executePageBulkExportJob(nextJob);
+    if (this.jobQueue.length > 0) {
+      while (this.canExecuteNextJob()) {
+        const nextJob = this.jobQueue.shift();
+        if (nextJob != null) {
+          this.jobsInProgress[nextJob.id.toString()] = { stream: undefined };
+          this.pageBulkExportService.executePageBulkExportJob(nextJob);
+        }
       }
     }
   }