Use ts as msgID for request

Signed-off-by: Cai Zhang <[email protected]>
milvus-io · Oct 31, 2024 · edc0ba7 · edc0ba7
1 parent b849249
commit edc0ba7
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go
@@ -177,18 +177,14 @@ func (queue *baseTaskQueue) Enqueue(t task) error {
 	var id UniqueID
 	if t.CanSkipAllocTimestamp() {
 		ts = tsoutil.ComposeTS(time.Now().UnixMilli(), 0)
-		id, err = globalMetaCache.AllocID(t.TraceCtx())
-		if err != nil {
-			return err
-		}
 	} else {
 		ts, err = queue.tsoAllocatorIns.AllocOne(t.TraceCtx())
 		if err != nil {
 			return err
 		}
-		// we always use same msg id and ts for now.
-		id = UniqueID(ts)
 	}
+	// we always use same msg id and ts for now.
+	id = UniqueID(ts)
 	t.SetTs(ts)
 	t.SetID(id)