Addressing PR comments.
This commit is contained in:
parent
fa585fe69d
commit
ea5d04e1d3
|
@ -10,7 +10,7 @@ import {
|
||||||
removeDeprecated,
|
removeDeprecated,
|
||||||
} from "../../automations/utils"
|
} from "../../automations/utils"
|
||||||
import { deleteEntityMetadata } from "../../utilities"
|
import { deleteEntityMetadata } from "../../utilities"
|
||||||
import { MetadataTypes, AUTOMATION_SYNC_TIMEOUT } from "../../constants"
|
import { MetadataTypes } from "../../constants"
|
||||||
import { setTestFlag, clearTestFlag } from "../../utilities/redis"
|
import { setTestFlag, clearTestFlag } from "../../utilities/redis"
|
||||||
import { context, cache, events, db as dbCore } from "@budibase/backend-core"
|
import { context, cache, events, db as dbCore } from "@budibase/backend-core"
|
||||||
import { automations, features } from "@budibase/pro"
|
import { automations, features } from "@budibase/pro"
|
||||||
|
@ -24,6 +24,7 @@ import {
|
||||||
import { getActionDefinitions as actionDefs } from "../../automations/actions"
|
import { getActionDefinitions as actionDefs } from "../../automations/actions"
|
||||||
import sdk from "../../sdk"
|
import sdk from "../../sdk"
|
||||||
import { builderSocket } from "../../websockets"
|
import { builderSocket } from "../../websockets"
|
||||||
|
import env from "../../environment"
|
||||||
|
|
||||||
async function getActionDefinitions() {
|
async function getActionDefinitions() {
|
||||||
return removeDeprecated(await actionDefs())
|
return removeDeprecated(await actionDefs())
|
||||||
|
@ -274,7 +275,9 @@ export async function trigger(ctx: UserCtx) {
|
||||||
automation,
|
automation,
|
||||||
{
|
{
|
||||||
fields: ctx.request.body.fields,
|
fields: ctx.request.body.fields,
|
||||||
timeout: ctx.request.body.timeout * 1000 || AUTOMATION_SYNC_TIMEOUT,
|
timeout:
|
||||||
|
ctx.request.body.timeout * 1000 ||
|
||||||
|
env.getDefaults().AUTOMATION_SYNC_TIMEOUT,
|
||||||
},
|
},
|
||||||
{ getResponses: true }
|
{ getResponses: true }
|
||||||
)
|
)
|
||||||
|
|
|
@ -11,7 +11,7 @@ import {
|
||||||
import * as triggers from "../triggers"
|
import * as triggers from "../triggers"
|
||||||
import { context } from "@budibase/backend-core"
|
import { context } from "@budibase/backend-core"
|
||||||
import { features } from "@budibase/pro"
|
import { features } from "@budibase/pro"
|
||||||
import { AUTOMATION_SYNC_TIMEOUT } from "../../constants"
|
import env from "../../environment"
|
||||||
|
|
||||||
export const definition: AutomationStepSchema = {
|
export const definition: AutomationStepSchema = {
|
||||||
name: "Trigger an automation",
|
name: "Trigger an automation",
|
||||||
|
@ -77,7 +77,8 @@ export async function run({ inputs }: AutomationStepInput) {
|
||||||
automation,
|
automation,
|
||||||
{
|
{
|
||||||
fields: { ...fieldParams },
|
fields: { ...fieldParams },
|
||||||
timeout: inputs.timeout * 1000 || AUTOMATION_SYNC_TIMEOUT,
|
timeout:
|
||||||
|
inputs.timeout * 1000 || env.getDefaults().AUTOMATION_SYNC_TIMEOUT,
|
||||||
},
|
},
|
||||||
{ getResponses: true }
|
{ getResponses: true }
|
||||||
)
|
)
|
||||||
|
|
|
@ -3,7 +3,7 @@ jest.spyOn(global.console, "error")
|
||||||
import * as setup from "./utilities"
|
import * as setup from "./utilities"
|
||||||
import * as automation from "../index"
|
import * as automation from "../index"
|
||||||
import { serverLogAutomation } from "../../tests/utilities/structures"
|
import { serverLogAutomation } from "../../tests/utilities/structures"
|
||||||
import { AUTOMATION_ASYNC_TIMEOUT } from "../../constants"
|
import env from "../../environment"
|
||||||
|
|
||||||
describe("Test triggering an automation from another automation", () => {
|
describe("Test triggering an automation from another automation", () => {
|
||||||
let config = setup.getConfig()
|
let config = setup.getConfig()
|
||||||
|
@ -25,7 +25,7 @@ describe("Test triggering an automation from another automation", () => {
|
||||||
const inputs: any = {
|
const inputs: any = {
|
||||||
automation: {
|
automation: {
|
||||||
automationId: newAutomation._id,
|
automationId: newAutomation._id,
|
||||||
timeout: AUTOMATION_ASYNC_TIMEOUT,
|
timeout: env.getDefaults().AUTOMATION_THREAD_TIMEOUT,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
const res = await setup.runStep(
|
const res = await setup.runStep(
|
||||||
|
@ -40,7 +40,7 @@ describe("Test triggering an automation from another automation", () => {
|
||||||
const inputs: any = {
|
const inputs: any = {
|
||||||
automation: {
|
automation: {
|
||||||
automationId: null,
|
automationId: null,
|
||||||
timeout: AUTOMATION_ASYNC_TIMEOUT,
|
timeout: env.getDefaults().AUTOMATION_THREAD_TIMEOUT,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
const res = await setup.runStep(
|
const res = await setup.runStep(
|
||||||
|
|
|
@ -1,6 +0,0 @@
|
||||||
import { Duration } from "@budibase/backend-core"
|
|
||||||
import env from "../environment"
|
|
||||||
|
|
||||||
const defaults = env.getDefaults()
|
|
||||||
export const AUTOMATION_SYNC_TIMEOUT = Duration.fromMinutes(2).toMs()
|
|
||||||
export const AUTOMATION_ASYNC_TIMEOUT = defaults.QUERY_THREAD_TIMEOUT
|
|
|
@ -6,8 +6,6 @@ import {
|
||||||
TableSourceType,
|
TableSourceType,
|
||||||
} from "@budibase/types"
|
} from "@budibase/types"
|
||||||
|
|
||||||
export * from "./automations"
|
|
||||||
|
|
||||||
export enum FilterTypes {
|
export enum FilterTypes {
|
||||||
STRING = "string",
|
STRING = "string",
|
||||||
FUZZY = "fuzzy",
|
FUZZY = "fuzzy",
|
||||||
|
|
|
@ -21,6 +21,7 @@ function parseIntSafe(number?: string) {
|
||||||
const DEFAULTS = {
|
const DEFAULTS = {
|
||||||
QUERY_THREAD_TIMEOUT: 10000,
|
QUERY_THREAD_TIMEOUT: 10000,
|
||||||
AUTOMATION_THREAD_TIMEOUT: 12000,
|
AUTOMATION_THREAD_TIMEOUT: 12000,
|
||||||
|
AUTOMATION_SYNC_TIMEOUT: 120000,
|
||||||
AUTOMATION_MAX_ITERATIONS: 200,
|
AUTOMATION_MAX_ITERATIONS: 200,
|
||||||
JS_PER_EXECUTION_TIME_LIMIT_MS: 1000,
|
JS_PER_EXECUTION_TIME_LIMIT_MS: 1000,
|
||||||
TEMPLATE_REPOSITORY: "app",
|
TEMPLATE_REPOSITORY: "app",
|
||||||
|
|
Loading…
Reference in New Issue