fix: Test Connection Lock (#3172)

fix: test connection lock
kubeshop · Sep 21, 2023 · 96510f2 · 96510f2
1 parent 126f909
commit 96510f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/http/controller.go b/server/http/controller.go
@@ -691,7 +691,6 @@ func (c *controller) TestConnection(ctx context.Context, dataStore openapi.DataS
 	wg := sync.WaitGroup{}
 	err := c.dsTestPipeline.Subscribe(job.ID, func(result testconnection.Job) {
 		job = result
-		c.dsTestPipeline.Unsubscribe(job.ID)
 		wg.Done()
 	})
 
@@ -702,6 +701,7 @@ func (c *controller) TestConnection(ctx context.Context, dataStore openapi.DataS
 	c.dsTestPipeline.Run(ctx, job)
 	wg.Add(1)
 	wg.Wait()
+	c.dsTestPipeline.Unsubscribe(job.ID)
 
 	if err := ds.Validate(); err != nil {
 		return openapi.Response(http.StatusBadRequest, err.Error()), err