@@ -504,43 +504,6 @@ func TestDataDrivenMMAIntegration(t *testing.T) {
504504 }
505505 as .MarkChangesAsFailed (changeIDs )
506506 return fmt .Sprintf ("marked %v as failed" , changeIDs )
507- case "mma-pre-apply" :
508- var requestCPU , raftCPU , writeBytes , logicalBytes int
509- var changeType string
510- var changeIDsStr string
511- d .ScanArgs (t , "request_cpu" , & requestCPU )
512- d .ScanArgs (t , "raft_cpu" , & raftCPU )
513- d .ScanArgs (t , "write_bytes" , & writeBytes )
514- d .ScanArgs (t , "logical_bytes" , & logicalBytes )
515- d .ScanArgs (t , "change_type" , & changeType )
516- d .ScanArgs (t , "change_ids" , & changeIDsStr )
517-
518- usage := allocator.RangeUsageInfo {
519- RequestCPUNanosPerSecond : float64 (requestCPU ),
520- RaftCPUNanosPerSecond : float64 (raftCPU ),
521- WriteBytesPerSecond : float64 (writeBytes ),
522- LogicalBytes : int64 (logicalBytes ),
523- }
524-
525- // Parse change IDs
526- changeIDStrs := strings .Split (changeIDsStr , "," )
527- var changeIDs []mmaprototype.ChangeID
528- for _ , idStr := range changeIDStrs {
529- id , err := strconv .Atoi (strings .TrimSpace (idStr ))
530- if err != nil {
531- d .Fatalf (t , "invalid change ID: %s" , idStr )
532- }
533- changeIDs = append (changeIDs , mmaprototype .ChangeID (id ))
534- }
535-
536- // For now, we'll create a simple PendingRangeChange instance
537- // In a real implementation, this would be more complex
538- prc := mmaprototype.PendingRangeChange {
539- RangeID : roachpb .RangeID (1 ), // Use a default range ID
540- }
541- syncID := as .MMAPreApply (usage , prc )
542- return fmt .Sprintf ("sync_change_id: %d" , syncID )
543-
544507 case "get-tracked-change" :
545508 var id int
546509 d .ScanArgs (t , "sync_id" , & id )
0 commit comments