From f3a90eb2d90ba1fb306ed5be417895de53665cc9 Mon Sep 17 00:00:00 2001 From: Przemek Delewski Date: Fri, 27 Dec 2024 18:06:22 +0100 Subject: [PATCH] Set context --- quesma/v2/core/quesma_builder.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/quesma/v2/core/quesma_builder.go b/quesma/v2/core/quesma_builder.go index f9e1fae6b..deeaf0446 100644 --- a/quesma/v2/core/quesma_builder.go +++ b/quesma/v2/core/quesma_builder.go @@ -46,7 +46,7 @@ func (quesma *Quesma) Start(ctx context.Context) { activeFrontendConnectors = append(activeFrontendConnectors, fc) } for _, pipeline := range quesma.pipelines { - newCtx := context.WithValue(context.Background(), "activeFrontendConnectors", activeFrontendConnectors) + newCtx := context.WithValue(ctx, "activeFrontendConnectors", activeFrontendConnectors) quesma.dependencies.Logger().Info().Msgf("Starting pipeline %v", pipeline) pipeline.Start(newCtx) activeFrontendConnectors = make([]FrontendConnector, 0)