Update will tests with pause and retry connect in the 311 case

test/test_mqtt.py

@@ -208,7 +208,16 @@ def on_message(**kwargs):
             ping_timeout_ms=10000,
             keep_alive_secs=30
         )
-        disconnecter.connect().result(TIMEOUT)
+
+        # A race condition exists in IoT Core where the interrupter may get refused rather than the existing
+        # connection getting dropped.  Loop until we successfully connect.
+        continue_connecting = True
+        while continue_connecting:
+            try:
+                disconnecter.connect().result(TIMEOUT)
+                continue_connecting = False
+            except:
+                pass
 
         # Receive message
         rcv = received.result(TIMEOUT)

test/test_mqtt5.py

@@ -1215,6 +1215,9 @@ def test_operation_will(self):
         suback_packet = subscribe_future.result(TIMEOUT)
         self.assertIsInstance(suback_packet, mqtt5.SubackPacket)
 
+        # wait a few seconds to minimize chance of eventual consistency race condition between subscribe and publish
+        time.sleep(2)
+
         disconnect_packet = mqtt5.DisconnectPacket(reason_code=mqtt5.DisconnectReasonCode.DISCONNECT_WITH_WILL_MESSAGE)
         client1.stop(disconnect_packet=disconnect_packet)
         callbacks1.future_stopped.result(TIMEOUT)