MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

enable stalled job disabling

This commit is contained in:
Rory Powell 2022-08-20 11:02:22 +01:00
parent b9c16331ce
commit 96c110abe6
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/server/src/automations/listeners.ts
View File

@ -4,11 +4,11 @@ import * as automation from "../threads/automation"
export const addListeners = (queue: Queue) => { export const addListeners = (queue: Queue) => {
logging(queue) logging(queue)
// handleStalled(queue) handleStalled(queue)
} }
const handleStalled = (queue: Queue) => { const handleStalled = (queue: Queue) => {
queue.on("active", async (job: Job) => { queue.on("stalled", async (job: Job) => {
await automation.removeStalled(job as AutomationEvent) await automation.removeStalled(job as AutomationEvent)
}) })
} }

4
packages/server/src/threads/automation.ts
View File

@ -473,9 +473,9 @@ export function execute(input: AutomationEvent, callback: WorkerCallback) {
}) })
} }
export const removeStalled = (input: AutomationEvent) => { export const removeStalled = async (input: AutomationEvent) => {
const appId = input.data.event.appId const appId = input.data.event.appId
doInAppContext(appId, async () => { await doInAppContext(appId, async () => {
const automationOrchestrator = new Orchestrator( const automationOrchestrator = new Orchestrator(
input.data.automation, input.data.automation,
input.data.event, input.data.event,