Start pusher engine in mocks

tim-barry · tim-barry · commit dec0d586bc1b · 2024-11-21T11:52:42.000-08:00
When using Unit, calling Ready would also start the engine.
With ComponentManager, we additionally need to invoke Start.
diff --git a/engine/testutil/mock/nodes.go b/engine/testutil/mock/nodes.go
@@ -140,6 +140,7 @@ func (n CollectionNode) Start(t *testing.T) {
 	n.IngestionEngine.Start(n.Ctx)
 	n.EpochManagerEngine.Start(n.Ctx)
 	n.ProviderEngine.Start(n.Ctx)
+	n.PusherEngine.Start(n.Ctx)
 }
 
 func (n CollectionNode) Ready() <-chan struct{} {

Original file line number	Diff line number	Diff line change
`@@ -140,6 +140,7 @@ func (n CollectionNode) Start(t *testing.T) {`
`140`	`140`	`n.IngestionEngine.Start(n.Ctx)`
`141`	`141`	`n.EpochManagerEngine.Start(n.Ctx)`
`142`	`142`	`n.ProviderEngine.Start(n.Ctx)`
	`143`	`+ n.PusherEngine.Start(n.Ctx)`
`143`	`144`	`}`
`144`	`145`
`145`	`146`	`func (n CollectionNode) Ready() <-chan struct{} {`