From da908cebfb2af2bf2c5dc5d91ab64e6497e491fa Mon Sep 17 00:00:00 2001 From: Kassian Sun Date: Sat, 22 Apr 2023 15:23:55 +0800 Subject: [PATCH] [migration] fix missing return --- plugin/migration/pipeline.go | 1 + 1 file changed, 1 insertion(+) diff --git a/plugin/migration/pipeline.go b/plugin/migration/pipeline.go index 18832f6f..f6b89186 100644 --- a/plugin/migration/pipeline.go +++ b/plugin/migration/pipeline.go @@ -1336,6 +1336,7 @@ func (p *DispatcherProcessor) cleanGatewayQueue(taskItem *task2.Task) { instanceID := taskItem.Metadata.Labels["execution_instance_id"] if instanceID == "" { log.Debugf("task [%s] not scheduled yet, skip cleaning queue", taskItem.ID) + return } instance.ID, _ = util.ExtractString(instanceID) _, err = orm.Get(&instance)