Commit c572ccfb by huangfusuper

Merge remote-tracking branches 'remotes/origin/developer' and 'remotes/origin/test' into myth-test

...@@ -33,8 +33,6 @@ ...@@ -33,8 +33,6 @@
</dependency> </dependency>
</dependencies> </dependencies>
<build> <build>
<plugins> <plugins>
<plugin> <plugin>
...@@ -45,15 +43,4 @@ ...@@ -45,15 +43,4 @@
</plugins> </plugins>
</build> </build>
<distributionManagement>
<repository>
<id>releases</id>
<url>http://10.0.120.2/repository/maven-releases/</url>
</repository>
<snapshotRepository>
<id>snapshots</id>
<url>http://10.0.120.2/repository/maven-snapshots/</url>
</snapshotRepository>
</distributionManagement>
</project> </project>
...@@ -520,7 +520,9 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -520,7 +520,9 @@ public class ApiFlowServiceImpl implements ApiFlowService {
RunRecording runRecording = runRecordingMapper.findRunRecordingByFlowIdAndRunId(flow.getFlowId(), runInfo.getRunId()); RunRecording runRecording = runRecordingMapper.findRunRecordingByFlowIdAndRunId(flow.getFlowId(), runInfo.getRunId());
ValidationUtil.dataNotNull(runRecording, "查无此运行记录"); ValidationUtil.dataNotNull(runRecording, "查无此运行记录");
//TODO 这里应该查询的是版本表 与版本号挂钩 //TODO 这里应该查询的是版本表 与版本号挂钩
NodeVersion nodeVersion = nodeVersionMapper.findNodeByNodeNameAndVersionNameAndFlowId(runInfo.getNodeName(), runRecording.getFlowVersionName(), runRecording.getFlowId()); //NodeVersion nodeVersion = nodeVersionMapper.findNodeByNodeNameAndVersionNameAndFlowId(runInfo.getNodeName(), runRecording.getFlowVersionName(), runRecording.getFlowId());
JobTaskRunLogWithBLOBs byRunIdAndFlowAndNode = jobTaskRunLogMapper.findByRunIdAndFlowAndNode(runRecording.getRunId(), runRecording.getFlowName(), runInfo.getNodeName());
NodeVersion nodeVersion = nodeVersionMapper.findNodeByNodeNameAndVersionNameAndFlowId(runInfo.getNodeName(), byRunIdAndFlowAndNode.getVersionName(), byRunIdAndFlowAndNode.getFlowId());
// //Node node = nodeMapper.getByNameAndFlow(runInfo.getNodeName(), flow.getFlowId()); // //Node node = nodeMapper.getByNameAndFlow(runInfo.getNodeName(), flow.getFlowId());
// ValidationUtil.dataNotNull(node, runInfo.getNodeName() + "节点不存在"); // ValidationUtil.dataNotNull(node, runInfo.getNodeName() + "节点不存在");
......
...@@ -55,8 +55,6 @@ ...@@ -55,8 +55,6 @@
</dependencies> </dependencies>
<build> <build>
<plugins> <plugins>
<!--<plugin> <!--<plugin>
......
...@@ -60,7 +60,6 @@ ...@@ -60,7 +60,6 @@
<!-- <build>--> <!-- <build>-->
<!-- <finalName>${project.artifactId}</finalName>--> <!-- <finalName>${project.artifactId}</finalName>-->
<!-- <plugins>--> <!-- <plugins>-->
......
...@@ -76,5 +76,4 @@ ...@@ -76,5 +76,4 @@
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>
\ No newline at end of file
package com.byit.task.annotations; package com.byit.task.annotations;
import com.byit.enums.CallMethodEnum;
import com.byit.rpc.remoting.invoker.route.LoadBalance; import com.byit.rpc.remoting.invoker.route.LoadBalance;
import java.lang.annotation.*; import java.lang.annotation.*;
...@@ -30,6 +29,4 @@ public @interface TaskClient { ...@@ -30,6 +29,4 @@ public @interface TaskClient {
* @return * @return
*/ */
long timeout() default -1; long timeout() default -1;
CallMethodEnum callMethodEnum() default CallMethodEnum.ASYNCHRONOUS;
} }
...@@ -31,5 +31,4 @@ ...@@ -31,5 +31,4 @@
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>
\ No newline at end of file
...@@ -35,6 +35,4 @@ ...@@ -35,6 +35,4 @@
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>
\ No newline at end of file
...@@ -20,5 +20,4 @@ ...@@ -20,5 +20,4 @@
</project> </project>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment