process rule sequentially

This commit is contained in:
Hongbo Wu
2024-08-23 17:07:05 +08:00
parent 2c7a88de81
commit 29bbba48c5

View File

@ -222,8 +222,6 @@ const triggerActions = async (
data: ItemEvent,
ruleEventType: RuleEventType
) => {
const actionPromises: Promise<unknown>[] = []
for (const rule of rules) {
let ast: LiqeQuery
let results: (ItemEvent | LibraryItem)[]
@ -276,15 +274,13 @@ const triggerActions = async (
ruleEventType,
}
actionPromises.push(actionFunc(actionObj))
try {
await actionFunc(actionObj)
} catch (error) {
logger.error('Error triggering rule action', error)
}
}
}
try {
await Promise.all(actionPromises)
} catch (error) {
logger.error('Error triggering rule actions', error)
}
}
export const triggerRule = async (jobData: TriggerRuleJobData) => {