Benature/omnivore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

enqueue export job

Browse Source
This commit is contained in:
Hongbo Wu
2024-02-22 13:38:51 +08:00
parent 8b848912c9
commit f94267ee1a
7 changed files with 82 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
packages/api/src/utils/createTask.ts
View File

@ -16,6 +16,7 @@ import {
} from '../generated/graphql'
import { BulkActionData, BULK_ACTION_JOB_NAME } from '../jobs/bulk_action'
import { CallWebhookJobData, CALL_WEBHOOK_JOB_NAME } from '../jobs/call_webhook'
import { ExportItemJobData, EXPORT_ITEM_JOB_NAME } from '../jobs/export_item'
import { THUMBNAIL_JOB } from '../jobs/find_thumbnail'
import {
queueRSSRefreshFeedJob,
@ -59,6 +60,7 @@ export const getJobPriority = (jobName: string): number => {
return 1
case TRIGGER_RULE_JOB_NAME:
case CALL_WEBHOOK_JOB_NAME:
case EXPORT_ITEM_JOB_NAME:
return 5
case BULK_ACTION_JOB_NAME:
case `${REFRESH_FEED_JOB_NAME}_high`:
@ -785,4 +787,16 @@ export const enqueueBulkAction = async (data: BulkActionData) => {
}
}
export const enqueueExportItem = async (jobData: ExportItemJobData) => {
const queue = await getBackendQueue()
if (!queue) {
return undefined
}
return queue.add(EXPORT_ITEM_JOB_NAME, jobData, {
attempts: 1,
priority: getJobPriority(EXPORT_ITEM_JOB_NAME),
})
}
export default createHttpTaskWithToken