开庭公告增量合并

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

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) {