This commit is contained in:
Peter Clement 2023-05-30 16:52:22 +01:00
parent 3119ba5a8d
commit ed6cd8144b
1 changed files with 9 additions and 2 deletions

View File

@ -38,7 +38,7 @@ const CRON_STEP_ID = triggerDefs.CRON.stepId
const STOPPED_STATUS = { success: true, status: AutomationStatus.STOPPED } const STOPPED_STATUS = { success: true, status: AutomationStatus.STOPPED }
function getLoopIterations(loopStep: LoopStep) { function getLoopIterations(loopStep: LoopStep) {
const binding = loopStep.inputs.binding let binding = loopStep.inputs.binding
if (!binding) { if (!binding) {
return 0 return 0
} }
@ -251,7 +251,7 @@ class Orchestrator {
return return
} }
} }
const start = performance.now()
for (let step of automation.definition.steps) { for (let step of automation.definition.steps) {
if (timeoutFlag) { if (timeoutFlag) {
break break
@ -344,6 +344,7 @@ class Orchestrator {
} }
} }
} }
if ( if (
index === env.AUTOMATION_MAX_ITERATIONS || index === env.AUTOMATION_MAX_ITERATIONS ||
index === parseInt(loopStep.inputs.iterations) index === parseInt(loopStep.inputs.iterations)
@ -432,6 +433,7 @@ class Orchestrator {
break break
} }
} }
console.log("end of loop!")
} }
if (loopStep && iterations === 0) { if (loopStep && iterations === 0) {
@ -472,6 +474,11 @@ class Orchestrator {
} }
} }
const end = performance.now()
const executionTime = end - start
console.log(`Execution time: ${executionTime} milliseconds`)
// store the logs for the automation run // store the logs for the automation run
await storeLog(this._automation, this.executionOutput) await storeLog(this._automation, this.executionOutput)
if (isProdAppID(this._appId) && isRecurring(automation) && metadata) { if (isProdAppID(this._appId) && isRecurring(automation) && metadata) {