Add mqtt_version parameter

aws · Dec 13, 2023 · 06bbe63 · 06bbe63
1 parent 9eb8709
commit 06bbe63
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/samples/utils/command_line_utils.py b/samples/utils/command_line_utils.py
@@ -475,6 +475,7 @@ def parse_sample_input_jobs():
         cmdData.input_thing_name = cmdUtils.get_command_required(CommandLineUtils.m_cmd_thing_name)
         cmdData.input_job_time = int(cmdUtils.get_command(CommandLineUtils.m_cmd_job_time, 5))
         cmdData.input_is_ci = cmdUtils.get_command(CommandLineUtils.m_cmd_is_ci, None) != None
+        cmdData.input_mqtt_version = int(cmdUtils.get_command(CommandLineUtils.m_cmd_mqtt_version, 5)
         return cmdData
 
     def parse_sample_input_mqtt5_custom_authorizer_connect():
@@ -877,3 +878,4 @@ def parse_sample_input_pkcs12_connect():
     m_cmd_pkcs12_file = "pkcs12_file"
     m_cmd_pkcs12_password = "pkcs12_password"
     m_cmd_region = "region"
+    m_cmd_mqtt_version = "mqtt_version"