From 4aeb055ac04eefe613338e181ca783f5a33de1d0 Mon Sep 17 00:00:00 2001
From: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Date: Fri, 20 Jan 2023 23:18:16 +0000
Subject: [PATCH] More cert test fixes

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
---
 tests/certification/pubsub/azure/eventhubs/eventhubs_test.go  | 4 +++-
 .../pubsub/azure/eventhubs/send-iot-device-events.sh          | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/tests/certification/pubsub/azure/eventhubs/eventhubs_test.go b/tests/certification/pubsub/azure/eventhubs/eventhubs_test.go
index b00a7df2f..6024c1ec0 100644
--- a/tests/certification/pubsub/azure/eventhubs/eventhubs_test.go
+++ b/tests/certification/pubsub/azure/eventhubs/eventhubs_test.go
@@ -162,7 +162,7 @@ func TestEventhubs(t *testing.T) {
 		return func(ctx flow.Context) error {
 			// assert for messages
 			for _, m := range messageWatchers {
-				m.Assert(ctx, 10*timeout)
+				m.Assert(ctx, 15*timeout)
 			}
 
 			return nil
@@ -269,6 +269,7 @@ func TestEventhubs(t *testing.T) {
 			embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*3),
 			componentRuntimeOptions(4),
 		)).
+		Step("wait", flow.Sleep(10*time.Second)).
 		Step(fmt.Sprintf("publish messages to topicToBeCreated: %s", topicToBeCreated), publishMessages(metadata, sidecarName4, topicToBeCreated, consumerGroup4)).
 		Step("verify if app4 has recevied messages published to newly created topic", assertMessages(10*time.Second, consumerGroup4)).
 
@@ -285,6 +286,7 @@ func TestEventhubs(t *testing.T) {
 			embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*4),
 			componentRuntimeOptions(5),
 		)).
+		Step("wait", flow.Sleep(10*time.Second)).
 		Step("add expected IOT messages (simulate add message to iot)", publishMessageAsDevice(consumerGroup5)).
 		Step("verify if app5 has recevied messages published to iot topic", assertMessages(40*time.Second, consumerGroup5)).
 		Step("wait", flow.Sleep(5*time.Second)).
diff --git a/tests/certification/pubsub/azure/eventhubs/send-iot-device-events.sh b/tests/certification/pubsub/azure/eventhubs/send-iot-device-events.sh
index 13662b2fc..8e93a34bc 100755
--- a/tests/certification/pubsub/azure/eventhubs/send-iot-device-events.sh
+++ b/tests/certification/pubsub/azure/eventhubs/send-iot-device-events.sh
@@ -30,7 +30,7 @@ fi
 az config set extension.use_dynamic_install=yes_without_prompt
 
 # login to azure
-az login --service-principal -u $AzureCertificationServicePrincipalClientId -p $AzureCertificationServicePrincipalClientSecret --tenant $AzureCertificationTenantId
+az login --service-principal -u $AzureCertificationServicePrincipalClientId -p $AzureCertificationServicePrincipalClientSecret --tenant $AzureCertificationTenantId > /dev/null
 
 # Create test device ID if not already present
 IOT_HUB_TEST_DEVICE_NAME="certification-test-device"