fixup! workload/changefeed: allow changefeed-cursor

wenyihu6 · wenyihu6 · commit ea305c158f5a · 2025-10-27T12:24:02.000-04:00
diff --git a/pkg/workload/cli/run.go b/pkg/workload/cli/run.go
@@ -509,8 +509,7 @@ func runRun(gen workload.Generator, urls []string, dbName string) error {
 
 			if *changefeed {
 				log.Dev.Infof(ctx, "adding changefeed to query load...")
-				err = changefeeds.AddChangefeedToQueryLoad(ctx, gen.(workload.ConnFlagser), dbName,  *changefeedResolvedTarget, *changefeedCursor, urls, reg, &ops)
-				
+				err = changefeeds.AddChangefeedToQueryLoad(ctx, gen.(workload.ConnFlagser), dbName, *changefeedResolvedTarget, *changefeedCursor, urls, reg, &ops)
 				if err != nil && !*tolerateErrors {
 					return errors.Wrapf(err, "failed to initialize changefeed")
 				}

Original file line number	Diff line number	Diff line change
`@@ -509,8 +509,7 @@ func runRun(gen workload.Generator, urls []string, dbName string) error {`
`509`	`509`
`510`	`510`	`if *changefeed {`
`511`	`511`	`log.Dev.Infof(ctx, "adding changefeed to query load...")`
`512`		`- err = changefeeds.AddChangefeedToQueryLoad(ctx, gen.(workload.ConnFlagser), dbName, changefeedResolvedTarget, changefeedCursor, urls, reg, &ops)`
`513`		`-`
	`512`	`+ err = changefeeds.AddChangefeedToQueryLoad(ctx, gen.(workload.ConnFlagser), dbName, changefeedResolvedTarget, changefeedCursor, urls, reg, &ops)`
`514`	`513`	`if err != nil && !*tolerateErrors {`
`515`	`514`	`return errors.Wrapf(err, "failed to initialize changefeed")`
`516`	`515`	`}`