[Fix] Fix the timeout alarm button is invalid (#10260)

3 years ago · 62b85b9cb3
19 changed files with 38 additions and 19 deletions
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-conditions.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-conditions.ts
@ -46,7 +46,8 @@ export function useConditions({
    dependTaskList: [],
    preTasks: [],
    successNode: 'success',
-    failedNode: 'failed'
+    failedNode: 'failed',
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-datax.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-datax.ts
@ -48,7 +48,8 @@ export function useDataX({
    dsType: 'MYSQL',
    dtType: 'MYSQL',
    preStatements: [],
-    postStatements: []
+    postStatements: [],
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-emr.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-emr.ts
@ -43,7 +43,8 @@ export function useEmr({
    failRetryTimes: 0,
    workerGroup: 'default',
    delayTime: 0,
-    timeout: 30
+    timeout: 30,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-flink.ts
@ -52,7 +52,8 @@ export function useFlink({
    taskManagerMemory: '2G',
    slot: 1,
    taskManager: 2,
-    parallelism: 1
+    parallelism: 1,
+    timeoutNotifyStrategy: ['WARN']
  })

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-http.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-http.ts
@ -49,7 +49,8 @@ export function useHttp({
    url: '',
    condition: '',
    connectTimeout: 60000,
-    socketTimeout: 60000
+    socketTimeout: 60000,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-jupyter.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-jupyter.ts
@ -42,7 +42,8 @@ export function useJupyter({
    failRetryTimes: 0,
    workerGroup: 'default',
    delayTime: 0,
-    timeout: 30
+    timeout: 30,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-k8s.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-k8s.ts
@ -43,7 +43,8 @@ export function useK8s({
    failRetryTimes: 0,
    workerGroup: 'default',
    delayTime: 0,
-    timeout: 30
+    timeout: 30,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mlflow.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mlflow.ts
@ -51,7 +51,8 @@ export function useMlflow({
    automlTool: 'flaml',
    mlflowCustomProjectParameters: [],
    delayTime: 0,
-    timeout: 30
+    timeout: 30,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mr.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-mr.ts
@ -43,7 +43,8 @@ export function useMr({
    workerGroup: 'default',
    delayTime: 0,
    timeout: 30,
-    programType: 'SCALA'
+    programType: 'SCALA',
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-pigeon.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-pigeon.ts
@ -42,7 +42,8 @@ export function usePigeon({
    workerGroup: 'default',
    delayTime: 0,
    timeout: 30,
-    targetJobName: ''
+    targetJobName: '',
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-procedure.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-procedure.ts
@ -46,7 +46,8 @@ export function useProcedure({
    timeout: 30,
    type: data?.taskParams?.type ? data?.taskParams?.type : 'MYSQL',
    datasource: data?.taskParams?.datasource,
-    method: data?.taskParams?.method
+    method: data?.taskParams?.method,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-python.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-python.ts
@ -44,7 +44,8 @@ export function usePython({
    workerGroup: 'default',
    delayTime: 0,
    timeout: 30,
-    rawScript: ''
+    rawScript: '',
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sea-tunnel.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sea-tunnel.ts
@ -48,7 +48,8 @@ export function useSeaTunnel({
    queue: 'default',
    master: 'yarn',
    masterUrl: '',
-    resourceFiles: []
+    resourceFiles: [],
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-spark.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-spark.ts
@ -51,7 +51,8 @@ export function useSpark({
    driverMemory: '512M',
    numExecutors: 2,
    executorMemory: '2G',
-    executorCores: 2
+    executorCores: 2,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sql.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sql.ts
@ -51,7 +51,8 @@ export function useSql({
    sqlType: '0',
    preStatements: [],
    postStatements: [],
-    udfs: []
+    udfs: [],
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sqoop.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sqoop.ts
@ -62,7 +62,8 @@ export function useSqoop({
    targetHiveCreateTable: false,
    targetHiveDropDelimiter: false,
    targetHiveOverWrite: true,
-    concurrency: 1
+    concurrency: 1,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sub-process.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-sub-process.ts
@ -45,7 +45,8 @@ export function useSubProcess({
    failRetryTimes: 0,
    workerGroup: 'default',
    delayTime: 0,
-    timeout: 30
+    timeout: 30,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-switch.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-switch.ts
@ -46,7 +46,8 @@ export function useSwitch({
    rawScript: '',
    switchResult: {},
    dependTaskList: [],
-    nextNode: undefined
+    nextNode: undefined,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-zeppelin.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/tasks/use-zeppelin.ts
@ -42,7 +42,8 @@ export function useZeppelin({
    failRetryTimes: 0,
    workerGroup: 'default',
    delayTime: 0,
-    timeout: 30
+    timeout: 30,
+    timeoutNotifyStrategy: ['WARN']
  } as INodeData)

  let extra: IJsonItem[] = []