Преглед на файлове

Merge remote-tracking branch 'origin/master'

许家凯 преди 4 години
родител
ревизия
97f614fe4f
променени са 2 файла, в които са добавени 10 реда и са изтрити 2 реда
  1. 9 1
      jobs/task-step01.yaml
  2. 1 1
      src/main/java/com/winhc/dataworks/flow/touch/Main.java

+ 9 - 1
jobs/task-step01.yaml

@@ -51,4 +51,12 @@ job:
           - _nodeId: 700003517752
             project: winhc_eci_dev
             source: winhc_eci.inc_ods_company_zxr_final_case_pre
-            target: winhc_eci_dev.inc_ods_company_zxr_final_case
+            target: winhc_eci_dev.inc_ods_company_zxr_final_case
+
+      #开庭公告增量合并
+      - taskName: inc_ods_company_court_open_announcement_pre
+        param:
+          - _nodeId: 700003517752
+            project: winhc_eci_dev
+            source: winhc_eci.inc_ods_company_court_open_announcement_pre
+            target: winhc_eci_dev.inc_ods_company_court_open_announcement

+ 1 - 1
src/main/java/com/winhc/dataworks/flow/touch/Main.java

@@ -272,7 +272,7 @@ public class Main {
                     failedTask++;
                     log.error("failure node:{} ", failure);
                     DingMsg error = new DingMsg("任务失败", taskInfo.getProject(), taskInfo.getFlow(), taskInfo.getTaskName(), String.join(",", failure), TaskFlowEnum.FAILURE.getMsg());
-                    dingUtils.send(error);
+//                    dingUtils.send(error);
                     failureTask.add(taskInfo);
                 } else {
                     if (await.size() != 0) {