fix

meyer9 · meyer9 · commit 93d3a253925c · 2026-04-01T05:26:03.000-07:00
diff --git a/runner/payload/loadtest/load_test_worker.go b/runner/payload/loadtest/load_test_worker.go
@@ -142,13 +142,13 @@ func (w *loadTestPayloadWorker) Stop(ctx context.Context) error {
 	return nil
 }
 
-func (w *loadTestPayloadWorker) SendTxs(ctx context.Context) error {
+func (w *loadTestPayloadWorker) SendTxs(ctx context.Context, _ int) (int, error) {
 	w.log.Info("Collecting txs from load test")
 	pendingTxs := w.proxyServer.PendingTxs()
 	w.proxyServer.ClearPendingTxs()
 
 	w.mempool.AddTransactions(pendingTxs)
-	return nil
+	return len(pendingTxs), nil
 }
 
 // defaultTransactions returns the default transaction mix as a yaml.Node.

Original file line number	Diff line number	Diff line change
`@@ -142,13 +142,13 @@ func (w *loadTestPayloadWorker) Stop(ctx context.Context) error {`
`142`	`142`	`return nil`
`143`	`143`	`}`
`144`	`144`
`145`		`-func (w *loadTestPayloadWorker) SendTxs(ctx context.Context) error {`
	`145`	`+func (w *loadTestPayloadWorker) SendTxs(ctx context.Context, _ int) (int, error) {`
`146`	`146`	`w.log.Info("Collecting txs from load test")`
`147`	`147`	`pendingTxs := w.proxyServer.PendingTxs()`
`148`	`148`	`w.proxyServer.ClearPendingTxs()`
`149`	`149`
`150`	`150`	`w.mempool.AddTransactions(pendingTxs)`
`151`		`- return nil`
	`151`	`+ return len(pendingTxs), nil`
`152`	`152`	`}`
`153`	`153`
`154`	`154`	`// defaultTransactions returns the default transaction mix as a yaml.Node.`