fix: fake source Stop with queue shutdown with drain ensure all item …

…be processed

Signed-off-by: zedongh <248348907@qq.com>

pkg/agent/config/source/fake_source.go

@@ -46,7 +46,7 @@ func (f *fakeSource) GetLatestConfig() (cfg *api.ColocationConfig, err error) {
 func (f *fakeSource) Stop() {
 	for {
 		if f.queue.Len() == 0 {
-			f.queue.ShutDown()
+			f.queue.ShutDownWithDrain()
 			return
 		}
 		time.Sleep(1 * time.Second)