Skip to content

Commit

Permalink
change flow url
Browse files Browse the repository at this point in the history
Signed-off-by: wmqwxb <[email protected]>
  • Loading branch information
wmqwxb committed Nov 9, 2023
1 parent 46e3e7b commit 6670758
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -417,7 +417,6 @@ public ResponseResult getDagDependencies(String param) {
@ResponseBody
public ResponseResult getModel(@Valid @RequestBody ComponentQueryDTO componentQueryDTO, BindingResult bindingResult) {


if (bindingResult.hasErrors()) {
FieldError errors = bindingResult.getFieldError();
return new ResponseResult<>(ErrorCode.ERROR_PARAMETER, errors.getDefaultMessage());
Expand All @@ -434,11 +433,11 @@ public ResponseResult getModel(@Valid @RequestBody ComponentQueryDTO componentQu

JSONObject resultObject = JSON.parseObject(result);
Integer retCode = resultObject.getInteger(Dict.CODE);
Object o = resultObject.get(Dict.DATA);
if (retCode != 0) {
return ResponseUtil.buildResponse(null, null);
}

return ResponseUtil.buildResponse(result, null);
return new ResponseResult(ErrorCode.SUCCESS.getCode(), resultObject.get(Dict.DATA));
}

@RequestMapping(value = "/tracking/component/output/data", method = RequestMethod.POST)
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/org/fedai/fate/board/global/Dict.java
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ public class Dict {
static public final String URL_JOB_STOP = "/v2/job/stop";
static public final String URL_JOB_QUERY = "/v2/job/list/query";
static public final String URL_JOB_DATAVIEW = "/v2/job/query";
static public final String URL_JOB_UPDATE = "/v2/job/update";
static public final String URL_JOB_UPDATE = "/v2/job/notes/add";
static public final String URL_JOB_RERUN = "/v2/job/rerun";
static public final String URL_DAG_DEPENDENCY = "/v2/job/dag/dependency";
static public final String URL_TASK_QUERY = "/v2/job/task/list/query";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ public class JobManagerService {
public List<JobDO> queryJobStatus() {
Map<String, Object> param = new HashMap<>();
List<String> statusList = new ArrayList<>();
statusList.add(Dict.STATUS_JOB_WAITING);
// statusList.add(Dict.STATUS_JOB_WAITING);
statusList.add(Dict.STATUS_JOB_RUNNING);

String statusStr = String.join(",", statusList);
Expand Down

0 comments on commit 6670758

Please sign in to comment.