wait for write stream to finish

2024-08-27 14:57:31 +08:00
parent 444c78f0cb
commit 48b3f736f0
4 changed files with 34 additions and 11 deletions
--- a/packages/api/src/queue-processor.ts
+++ b/packages/api/src/queue-processor.ts
@ -35,6 +35,7 @@ import {
  expireFoldersJob,
  EXPIRE_FOLDERS_JOB_NAME,
 } from './jobs/expire_folders'
+import { exportJob, EXPORT_JOB_NAME } from './jobs/export'
 import { findThumbnail, THUMBNAIL_JOB } from './jobs/find_thumbnail'
 import {
  generatePreviewContent,
@ -223,6 +224,8 @@ export const createWorker = (connection: ConnectionOptions) =>
            return pruneTrashJob(job.data)
          case EXPIRE_FOLDERS_JOB_NAME:
            return expireFoldersJob()
+          case EXPORT_JOB_NAME:
+            return exportJob(job.data)
          default:
            logger.warning(`[queue-processor] unhandled job: ${job.name}`)
        }