feat: optimizing delay tasks

TencentBlueKing · Nov 27, 2024 · 17b7300 · 17b7300
1 parent c6758e0
commit 17b7300
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bcs-common/common/task/brokers/etcd/delay_task.go b/bcs-common/common/task/brokers/etcd/delay_task.go
@@ -51,7 +51,7 @@ func makeDelayTask(kv *mvccpb.KeyValue) (*delayTask, error) {
 	taskKey := fmt.Sprintf("%s/%s", parts[6], parts[7])
 
 	// eta-{ms} -> {ms}
-	etaStr := parts[5][4:]
+	etaStr := strings.TrimPrefix(parts[5], "eta-")
 
 	etaMilli, err := strconv.Atoi(etaStr)
 	if err != nil {