Close channel to prevent deadlock

arcalot · Jul 29, 2024 · 2f9ceef · 2f9ceef
1 parent 5c319a5
commit 2f9ceef
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/connector/connector_test.go b/internal/connector/connector_test.go
@@ -90,6 +90,7 @@ func RunStep(t *testing.T, connector deployer.Connector, moduleName string, step
 		receivedSignalsChan,
 		emittedSignalsChan,
 	)
+	close(receivedSignalsChan) // Necessary to prevent a deadlock
 	assert.NoError(t, atpClient.Close())
 
 	return executionResult.OutputID, executionResult.OutputData, executionResult.Error