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

[migration] fix missing return

This commit is contained in:
Kassian Sun 2023-04-22 15:23:55 +08:00
parent 6a531eba8d
commit da908cebfb
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
plugin/migration/pipeline.go
View File

@ -1336,6 +1336,7 @@ func (p *DispatcherProcessor) cleanGatewayQueue(taskItem *task2.Task) {
instanceID := taskItem.Metadata.Labels["execution_instance_id"] instanceID := taskItem.Metadata.Labels["execution_instance_id"]
if instanceID == "" { if instanceID == "" {
log.Debugf("task [%s] not scheduled yet, skip cleaning queue", taskItem.ID) log.Debugf("task [%s] not scheduled yet, skip cleaning queue", taskItem.ID)
return
} }
instance.ID, _ = util.ExtractString(instanceID) instance.ID, _ = util.ExtractString(instanceID)
_, err = orm.Get(&instance) _, err = orm.Get(&instance)