From 02ce416b001ceaf97c6e84f5d16a9c902d9825dd Mon Sep 17 00:00:00 2001 From: Lukas Berk Date: Mon, 24 Aug 2020 15:58:38 -0400 Subject: [PATCH] broker conformance: Add wait for service endpoint (transformer pod) --- test/conformance/helpers/broker_data_plane_test_helper.go | 1 + 1 file changed, 1 insertion(+) diff --git a/test/conformance/helpers/broker_data_plane_test_helper.go b/test/conformance/helpers/broker_data_plane_test_helper.go index 610a53f1e16..3c0bb15e8d8 100644 --- a/test/conformance/helpers/broker_data_plane_test_helper.go +++ b/test/conformance/helpers/broker_data_plane_test_helper.go @@ -332,6 +332,7 @@ func BrokerV1Beta1ConsumerDataPlaneTestHelper( msg, ) client.CreatePodOrFail(transformPod, testlib.WithService("transformer-pod")) + client.WaitForServiceEndpointsOrFail("transformer-pod", 1) transformTrigger := client.CreateTriggerOrFailV1Beta1( "transform-trigger", resources.WithBrokerV1Beta1(broker.Name),