mirror of
https://github.com/docmost/docmost.git
synced 2026-05-21 09:14:07 +08:00
Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ed0501a864 | |||
| aa0c37bd68 | |||
| a5858bc470 |
@@ -481,7 +481,7 @@ export class PageService {
|
|||||||
);
|
);
|
||||||
|
|
||||||
await this.aiQueue.add(QueueJob.PAGE_MOVED_TO_SPACE, {
|
await this.aiQueue.add(QueueJob.PAGE_MOVED_TO_SPACE, {
|
||||||
pageId: pageIdsToMove,
|
pageIds: pageIdsToMove,
|
||||||
workspaceId: rootPage.workspaceId,
|
workspaceId: rootPage.workspaceId,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
Submodule apps/server/src/ee updated: b30e92f6a0...9e5f64d95d
@@ -66,8 +66,11 @@ export class FileTaskProcessor extends WorkerHost implements OnModuleDestroy {
|
|||||||
|
|
||||||
@OnWorkerEvent('failed')
|
@OnWorkerEvent('failed')
|
||||||
async onFailed(job: Job) {
|
async onFailed(job: Job) {
|
||||||
|
const fileTaskId = job.data?.fileTaskId;
|
||||||
this.logger.error(
|
this.logger.error(
|
||||||
`Error processing ${job.name} job. File Task ID: ${job.data?.fileTaskId}. Reason: ${job.failedReason}`,
|
fileTaskId
|
||||||
|
? `Error processing ${job.name} job. File Task ID: ${fileTaskId}. Reason: ${job.failedReason}`
|
||||||
|
: `Error processing ${job.name} job. Reason: ${job.failedReason}`,
|
||||||
);
|
);
|
||||||
|
|
||||||
if (job.name === QueueJob.IMPORT_TASK) {
|
if (job.name === QueueJob.IMPORT_TASK) {
|
||||||
@@ -79,8 +82,11 @@ export class FileTaskProcessor extends WorkerHost implements OnModuleDestroy {
|
|||||||
|
|
||||||
@OnWorkerEvent('completed')
|
@OnWorkerEvent('completed')
|
||||||
async onCompleted(job: Job) {
|
async onCompleted(job: Job) {
|
||||||
|
const fileTaskId = job.data?.fileTaskId;
|
||||||
this.logger.log(
|
this.logger.log(
|
||||||
`Completed ${job.name} job for File task ID ${job.data?.fileTaskId}`,
|
fileTaskId
|
||||||
|
? `Completed ${job.name} job for File task ID ${fileTaskId}`
|
||||||
|
: `Completed ${job.name} job`,
|
||||||
);
|
);
|
||||||
|
|
||||||
if (job.name === QueueJob.IMPORT_TASK) {
|
if (job.name === QueueJob.IMPORT_TASK) {
|
||||||
|
|||||||
Reference in New Issue
Block a user