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

[migration] fix pending_stop checking logic

This commit is contained in:
Kassian Sun 2023-04-04 16:02:31 +08:00
parent 400bd2d002
commit 87d28c9cfc
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
plugin/migration/pipeline.go
View File

@ -274,6 +274,13 @@ func (p *DispatcherProcessor) handlePendingStopMajorTask(taskItem *task2.Task) e
"query": util.MapStr{ "query": util.MapStr{
"bool": util.MapStr{ "bool": util.MapStr{
"must": []util.MapStr{ "must": []util.MapStr{
{
"term": util.MapStr{
"parent_id": util.MapStr{
"value": taskItem.ID,
},
},
},
{ {
"term": util.MapStr{ "term": util.MapStr{
"metadata.labels.business_id": "index_migration", "metadata.labels.business_id": "index_migration",