Add back consumer chain stopping

p-offtermatt · p-offtermatt · commit 0e584c331b04 · 2023-11-30T11:22:01.000+01:00
diff --git a/tests/mbt/driver/mbt_test.go b/tests/mbt/driver/mbt_test.go
@@ -246,6 +246,11 @@ func RunItfTrace(t *testing.T, path string) {
 				)
 			}
 
+			// stop consumers
+			for _, consumer := range consumersToStop {
+				driver.providerKeeper().StopConsumerChain(driver.providerCtx(), consumer.Value.(string), true)
+			}
+
 			// reset the times for the consumers that were not stopped or started just now
 			// their times were messed up by the coordinator
 			for consumer, timestamp := range lastTimestamps {

Original file line number	Diff line number	Diff line change
`@@ -246,6 +246,11 @@ func RunItfTrace(t *testing.T, path string) {`
`246`	`246`	`)`
`247`	`247`	`}`
`248`	`248`
	`249`	`+ // stop consumers`
	`250`	`+ for _, consumer := range consumersToStop {`
	`251`	`+ driver.providerKeeper().StopConsumerChain(driver.providerCtx(), consumer.Value.(string), true)`
	`252`	`+ }`
	`253`	`+`
`249`	`254`	`// reset the times for the consumers that were not stopped or started just now`
`250`	`255`	`// their times were messed up by the coordinator`
`251`	`256`	`for consumer, timestamp := range lastTimestamps {`