1. update test sample time out time. 2.wait for subscribe future result

Author: xiazhvera

deviceadvisor/script/DATestRun.py

@@ -188,7 +188,7 @@ def delete_thing_with_certi(thingName, certiId, certiArn):
             elif (test_result_responds['status'] == 'RUNNING' and 
             test_result_responds['testResult']['groups'][0]['tests'][0]['status'] == 'RUNNING'):
                 exe_path = os.path.join("deviceadvisor/tests/",DATestConfig['test_exe_path'][test_name])
-                result = subprocess.run('python3 ' + exe_path, timeout = 60*5, shell = True)
+                result = subprocess.run('python3 ' + exe_path, timeout = 60*2, shell = True)
             # If the test finalizing then store the test result
             elif (test_result_responds['status'] != 'RUNNING'):
                 test_result[test_name] = test_result_responds['status']

deviceadvisor/tests/mqtt_subscribe.py

@@ -28,6 +28,7 @@
     subscribe_future, packet_id = mqtt_connection.subscribe(
         topic=DATestUtils.topic,
         qos=mqtt.QoS.AT_MOST_ONCE)
+    subscribe_future.result()
 
     # Disconnect
     disconnect_future = mqtt_connection.disconnect()