Merge pull request #503 from wangxinbiao/main

chore:Add gql for retrieving details logs.
kubeagi · Jan 5, 2024 · a6c5fc8 · a6c5fc8
2 parents 1d0156c + 38165df
commit a6c5fc8
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 10 deletions.
diff --git a/apiserver/graph/generated/generated.go b/apiserver/graph/generated/generated.go
diff --git a/apiserver/graph/impl/dataprocessing.resolvers.go b/apiserver/graph/impl/dataprocessing.resolvers.go
diff --git a/apiserver/graph/schema/dataprocessing.gql b/apiserver/graph/schema/dataprocessing.gql
@@ -118,6 +118,16 @@ query checkDataProcessTaskName($input: CheckDataProcessTaskNameInput){
   }
 }
 
+query getLogInfo($input: DataProcessDetailsInput){
+  dataProcess {
+    getLogInfo(input: $input) {
+      status
+      data 
+      message
+    }
+  }
+}
+
 mutation createDataProcessTask($input: AddDataProcessInput) {
   dataProcess {
     createDataProcessTask(input: $input) {

diff --git a/apiserver/graph/schema/dataprocessing.graphqls b/apiserver/graph/schema/dataprocessing.graphqls
@@ -20,7 +20,7 @@ type DataProcessQuery {
   # 检验名称是否重复
   checkDataProcessTaskName(input: CheckDataProcessTaskNameInput): DataProcessResponse
   # 日志信息
-  getLogInfo(input: DeleteDataProcessInput): DataProcessResponse
+  getLogInfo(input: DataProcessDetailsInput): DataProcessResponse
 }
 
 

diff --git a/apiserver/pkg/dataprocessing/dataprocessing.go b/apiserver/pkg/dataprocessing/dataprocessing.go
@@ -232,7 +232,7 @@ func CheckDataProcessTaskName(ctx context.Context, c dynamic.Interface, obj *gen
 	return data, nil
 }
 
-func GetLogInfo(ctx context.Context, c dynamic.Interface, obj *generated.DataProcessQuery, input *generated.DeleteDataProcessInput) (*generated.DataProcessResponse, error) {
+func GetLogInfo(ctx context.Context, c dynamic.Interface, obj *generated.DataProcessQuery, input *generated.DataProcessDetailsInput) (*generated.DataProcessResponse, error) {
 	// prepare http request
 	jsonParams, err := json.Marshal(input)
 	if err != nil {