jeffemmett
/
postiz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: check also waiting

This commit is contained in:
Nevo David 2025-08-09 00:07:46 +07:00
parent 00fd1512c5
commit 85d015f349
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/cron/src/tasks/check.missing.queues.ts
View File

@ -19,9 +19,11 @@ export class CheckMissingQueues {
id: p.id,
publishDate: p.publishDate,
isJob:
(await this._workerServiceProducer
.getQueue('post')
.getJobState(p.id)) === 'delayed',
['delayed', 'waiting'].indexOf(
await this._workerServiceProducer
.getQueue('post')
.getJobState(p.id)
) > -1,
}))
)
).filter((p) => !p.isJob);

8
apps/cron/src/tasks/post.now.pending.queues.ts
View File

@ -18,9 +18,11 @@ export class PostNowPendingQueues {
id: p.id,
publishDate: p.publishDate,
isJob:
(await this._workerServiceProducer
.getQueue('post')
.getJobState(p.id)) === 'delayed',
['delayed', 'waiting'].indexOf(
await this._workerServiceProducer
.getQueue('post')
.getJobState(p.id)
) > -1,
}))
)
).filter((p) => !p.isJob);