CodeMirror/budibase
1
0
Fork 0
mirror of synced 2024-08-18 11:31:28 +12:00
Code Issues Projects Releases Wiki Activity

Merge pull request #7382 from Budibase/handle-stalled-crons

Browse source 
Handle stalled crons
This commit is contained in:
Rory Powell 2022-08-20 12:31:23 +01:00 committed by GitHub
commit b66c385e49
3 changed files with 8 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,

4
packages/server/src/utilities/queue/inMemoryQueue.js
View file

@ -113,6 +113,10 @@ class InMemoryQueue {
async getJob() { async getJob() {
return {} return {}
} }
on() {
// do nothing
}
} }
module.exports = InMemoryQueue module.exports = InMemoryQueue