|
|
@@ -49,8 +49,11 @@ func GetCloudbrainTask(ctx *context.APIContext) { |
|
|
err error |
|
|
err error |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
jobName := ctx.Params(":jobname") |
|
|
|
|
|
job, err := models.GetCloudbrainByName(jobName) |
|
|
|
|
|
|
|
|
// jobName := ctx.Params(":jobname") |
|
|
|
|
|
// job, err := models.GetCloudbrainByName(jobName) |
|
|
|
|
|
jobID := ctx.Params(":jobid") |
|
|
|
|
|
repoID := ctx.Repo.Repository.ID |
|
|
|
|
|
job, err := models.GetRepoCloudBrainByJobID(repoID, jobID) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
ctx.Data["error"] = err.Error() |
|
|
ctx.Data["error"] = err.Error() |
|
|
} |
|
|
} |
|
|
@@ -83,6 +86,7 @@ func GetCloudbrainTask(ctx *context.APIContext) { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
ctx.JSON(http.StatusOK, map[string]interface{}{ |
|
|
ctx.JSON(http.StatusOK, map[string]interface{}{ |
|
|
|
|
|
"JobID": result.Config.JobID, |
|
|
"JobName": result.Config.JobName, |
|
|
"JobName": result.Config.JobName, |
|
|
"JobStatus": result.JobStatus.State, |
|
|
"JobStatus": result.JobStatus.State, |
|
|
"SubState": result.JobStatus.SubState, |
|
|
"SubState": result.JobStatus.SubState, |
|
|
@@ -93,8 +97,11 @@ func GetCloudbrainTask(ctx *context.APIContext) { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func CloudbrainGetLog(ctx *context.Context) { |
|
|
func CloudbrainGetLog(ctx *context.Context) { |
|
|
jobName := ctx.Params(":jobname") |
|
|
|
|
|
job, err := models.GetCloudbrainByName(jobName) |
|
|
|
|
|
|
|
|
// jobName := ctx.Params(":jobname") |
|
|
|
|
|
// job, err := models.GetCloudbrainByName(jobName) |
|
|
|
|
|
jobID := ctx.Params(":jobid") |
|
|
|
|
|
repoID := ctx.Repo.Repository.ID |
|
|
|
|
|
job, err := models.GetRepoCloudBrainByJobID(repoID, jobID) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Error("GetCloudbrainByJobID failed: %v", err, ctx.Data["MsgID"]) |
|
|
log.Error("GetCloudbrainByJobID failed: %v", err, ctx.Data["MsgID"]) |
|
|
ctx.ServerError(err.Error(), err) |
|
|
ctx.ServerError(err.Error(), err) |
|
|
@@ -141,7 +148,7 @@ func CloudbrainGetLog(ctx *context.Context) { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
ctx.JSON(http.StatusOK, map[string]interface{}{ |
|
|
ctx.JSON(http.StatusOK, map[string]interface{}{ |
|
|
"JobName": jobName, |
|
|
|
|
|
|
|
|
"JobID": jobID, |
|
|
"Content": content, |
|
|
"Content": content, |
|
|
}) |
|
|
}) |
|
|
|
|
|
|
|
|
|