司法案件job时间延长

src/main/java/com/winhc/dataworks/flow/touch/Main.java

@@ -141,7 +141,11 @@ public class Main {
                 } else {
                     String odpsCmdPath = commandLine.getOptionValue("odps");
                     dd.send(msg);
-                    bean.start(bizDate, jobs, odpsCmdPath);
+                    Long time = 90l;
+                    if (fileName.endsWith("step06.yaml")) {
+                        time = 60 * 6l;
+                    }
+                    bean.start(bizDate, jobs, odpsCmdPath, time);
                     // 指定job结束后发送通知
                     if (fileName.endsWith("step03.yaml")) {
                         SendJobStatus sendJobStatus = context.getBean(SendJobStatus.class);
@@ -165,13 +169,13 @@ public class Main {
     }
 
     @SneakyThrows
-    private void start(String bizDate, List<DataWorksFlowJob> jobs, String odpsCmdHome) {
+    private void start(String bizDate, List<DataWorksFlowJob> jobs, String odpsCmdHome, Long time) {
         //为所有项目空间启动守护线程
         String accessKeyId = dataWorksAccessProperties.getAccessKeyId();
         String accessKeySecret = dataWorksAccessProperties.getAccessKeySecret();
         Set<String> ps = jobs.stream().map(DataWorksFlowJob::getProject).collect(Collectors.toSet());
         for (String p : ps) {
-            new SparkDaemonThread(p, accessKeyId, accessKeySecret, odpsCmdHome, 90L).start();
+            new SparkDaemonThread(p, accessKeyId, accessKeySecret, odpsCmdHome, time).start();
         }
 
         //运行job，并接收失败参数，最大重试三次