|
|
@@ -47,9 +47,13 @@ func State(c *gin.Context) {
|
|
|
}
|
|
|
if cache.Task.Info.TaskId == taskId {
|
|
|
if cache.Env == "cicv" {
|
|
|
+ infra.GlobalLogger.Infof("运行环境为 cicv")
|
|
|
callbackUri = infra.ApplicationYaml.K8s.CallbackUriCicv
|
|
|
- } else {
|
|
|
+ } else if cache.Env == "pji" {
|
|
|
+ infra.GlobalLogger.Infof("运行环境为 pji")
|
|
|
callbackUri = infra.ApplicationYaml.K8s.CallbackUriPji
|
|
|
+ } else {
|
|
|
+ infra.GlobalLogger.Infof("运行环境为【%v】", cache.Env)
|
|
|
}
|
|
|
// 1 获取任务id关联的节点
|
|
|
nodeName, _ := infra.GlobalRedisClient.Get(global.KeyTaskToNode + ":" + taskId).Result()
|
