Compare commits

..

1 Commits

Author SHA1 Message Date
Philipinho 779f9604a7 update packages 2026-05-20 18:28:04 +01:00
3 changed files with 4 additions and 10 deletions
@@ -481,7 +481,7 @@ export class PageService {
);
await this.aiQueue.add(QueueJob.PAGE_MOVED_TO_SPACE, {
pageIds: pageIdsToMove,
pageId: pageIdsToMove,
workspaceId: rootPage.workspaceId,
});
}
@@ -66,11 +66,8 @@ export class FileTaskProcessor extends WorkerHost implements OnModuleDestroy {
@OnWorkerEvent('failed')
async onFailed(job: Job) {
const fileTaskId = job.data?.fileTaskId;
this.logger.error(
fileTaskId
? `Error processing ${job.name} job. File Task ID: ${fileTaskId}. Reason: ${job.failedReason}`
: `Error processing ${job.name} job. Reason: ${job.failedReason}`,
`Error processing ${job.name} job. File Task ID: ${job.data?.fileTaskId}. Reason: ${job.failedReason}`,
);
if (job.name === QueueJob.IMPORT_TASK) {
@@ -82,11 +79,8 @@ export class FileTaskProcessor extends WorkerHost implements OnModuleDestroy {
@OnWorkerEvent('completed')
async onCompleted(job: Job) {
const fileTaskId = job.data?.fileTaskId;
this.logger.log(
fileTaskId
? `Completed ${job.name} job for File task ID ${fileTaskId}`
: `Completed ${job.name} job`,
`Completed ${job.name} job for File task ID ${job.data?.fileTaskId}`,
);
if (job.name === QueueJob.IMPORT_TASK) {