floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[migration] fix GetChildTasks

This commit is contained in:
Kassian Sun 2023-05-17 16:57:27 +08:00
parent 556a3d49d8
commit 8d27425fc0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/migration/util/orm.go
View File

@ -32,7 +32,7 @@ func GetChildTasks(elasticsearch, indexName string, taskID string, taskType stri
if len(status) > 0 { if len(status) > 0 {
musts = append(musts, util.MapStr{ musts = append(musts, util.MapStr{
"terms": util.MapStr{ "terms": util.MapStr{
"status": []string{task.StatusRunning, task.StatusPendingStop, task.StatusReady}, "status": status,
}, },
}) })
} }
@ -47,7 +47,7 @@ func GetChildTasks(elasticsearch, indexName string, taskID string, taskType stri
return GetTasks(elasticsearch, indexName, queryDsl) return GetTasks(elasticsearch, indexName, queryDsl)
} }
func GetTasks(elasticsearch, indexName string, query interface{}) ([]task.Task, error) { func GetTasks(elasticsearch, indexName string, query util.MapStr) ([]task.Task, error) {
esClient := elastic.GetClient(elasticsearch) esClient := elastic.GetClient(elasticsearch)
res, err := esClient.SearchWithRawQueryDSL(indexName, util.MustToJSONBytes(query)) res, err := esClient.SearchWithRawQueryDSL(indexName, util.MustToJSONBytes(query))
if err != nil { if err != nil {