feat: BMW: 数据源刷新任务一致性保障 --story=121105929 (#656)

TencentBlueKing · Dec 10, 2024 · ddea5ee · ddea5ee
1 parent 302ebd6
commit ddea5ee
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/bk-monitor-worker/internal/metadata/task/config_refresh.go b/pkg/bk-monitor-worker/internal/metadata/task/config_refresh.go
@@ -286,8 +286,7 @@ func RefreshDatasource(ctx context.Context, t *t.Task) error {
 				logger.Warnf("RefreshDatasource: data_id [%v] is not enable or created from bkdata, skip", ds.BkDataId)
 				return
 			}
-
-			dsSvc := service.NewDataSourceSvc(&latestDataSource)
+			dsSvc := service.NewDataSourceSvc(&ds)
 			consulClient, err := consul.GetInstance()
 			if err != nil {
 				logger.Errorf("RefreshDatasource: data_id [%v] failed to get consul client, %v,skip", dsSvc.BkDataId, err)