diff options
Diffstat (limited to 'cmd/gotosocial/action/testrig/testrig.go')
-rw-r--r-- | cmd/gotosocial/action/testrig/testrig.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cmd/gotosocial/action/testrig/testrig.go b/cmd/gotosocial/action/testrig/testrig.go index 7b99a2a13..99f366fbe 100644 --- a/cmd/gotosocial/action/testrig/testrig.go +++ b/cmd/gotosocial/action/testrig/testrig.go @@ -155,10 +155,6 @@ var Start action.GTSAction = func(ctx context.Context) error { } testrig.StandardStorageSetup(state.Storage, "./testrig/media") - // Initialize workers. - testrig.StartNoopWorkers(state) - defer testrig.StopWorkers(state) - // build backend handlers transportController := testrig.NewTestTransportController(state, testrig.NewMockHTTPClient(func(req *http.Request) (*http.Response, error) { r := io.NopCloser(bytes.NewReader([]byte{})) @@ -199,6 +195,10 @@ var Start action.GTSAction = func(ctx context.Context) error { processor := testrig.NewTestProcessor(state, federator, emailSender, mediaManager) + // Initialize workers. + testrig.StartWorkers(state, processor.Workers()) + defer testrig.StopWorkers(state) + // Initialize metrics. if err := metrics.Initialize(state.DB); err != nil { return fmt.Errorf("error initializing metrics: %w", err) |