diff --git a/awscrt/mqtt.py b/awscrt/mqtt.py index 8d92acc38..5a96f5632 100644 --- a/awscrt/mqtt.py +++ b/awscrt/mqtt.py @@ -228,7 +228,7 @@ class Connection(NativeResource): The `session_present` bool in the connection callback informs whether an existing session was successfully resumed. If an existing session is resumed, the server remembers previous subscriptions - and sends mesages (with QoS1 or higher) that were published while the client was offline. + and sends messages (with QoS1 or higher) that were published while the client was offline. on_connection_interrupted: Optional callback invoked whenever the MQTT connection is lost. The MQTT client will automatically attempt to reconnect. diff --git a/awscrt/mqtt5.py b/awscrt/mqtt5.py index 054deb8b6..7c53462a1 100644 --- a/awscrt/mqtt5.py +++ b/awscrt/mqtt5.py @@ -2015,7 +2015,7 @@ def new_connection(self, on_connection_interrupted=None, on_connection_resumed=N protocol_operation_timeout_ms=self.adapter_options.ack_timeout_secs * 1000, socket_options=self.adapter_options.socket_options, - # For the arugments below, set it to `None` will directly use the options from mqtt5 client underlying. + # For the arguments below, set it to `None` will directly use the options from mqtt5 client underlying. will=None, username=None, password=None, diff --git a/codebuild/mqtt5_test_setup.sh b/codebuild/mqtt5_test_setup.sh index fd19f5bf9..a6b750ef0 100755 --- a/codebuild/mqtt5_test_setup.sh +++ b/codebuild/mqtt5_test_setup.sh @@ -91,7 +91,7 @@ else return 1 fi -# Set the certificate and key paths (absolute paths for best compatbility) +# Set the certificate and key paths (absolute paths for best compatibility) export AWS_TEST_MQTT5_CERTIFICATE_FILE="${PWD}/crt_certificate.pem" export AWS_TEST_MQTT5_KEY_FILE="${PWD}/crt_privatekey.pem" diff --git a/mqtt_test.py b/mqtt_test.py index 7f9007c0b..b988d58fa 100644 --- a/mqtt_test.py +++ b/mqtt_test.py @@ -122,7 +122,7 @@ def on_receive_message(topic, payload, dup, qos, retain, **kwargs): assert(publish_results['packet_id'] == publish_packet_id) # Receive Message -print("Waiting to receive messsage") +print("Waiting to receive message") assert(receive_event.wait(TIMEOUT)) assert(receive_results['topic'] == TOPIC) assert(receive_results['payload'].decode() == MESSAGE) diff --git a/s3_benchmark.py b/s3_benchmark.py index 895ff8397..f5f096179 100644 --- a/s3_benchmark.py +++ b/s3_benchmark.py @@ -130,7 +130,7 @@ def on_body(offset, chunk, **kwargs): # if not os.path.exists(file_name): # open(file_name, 'a').close() # with open(file_name, 'rb+') as f: - # # seems like the seek here may srew up the file. + # # seems like the seek here may screw up the file. # f.seek(offset) # f.write(chunk) diff --git a/source/module.h b/source/module.h index c0e5ad38b..d7254d8c4 100644 --- a/source/module.h +++ b/source/module.h @@ -41,7 +41,7 @@ int PyObject_GetAttrAsIntEnum(PyObject *o, const char *class_name, const char *a /* Checks if the named attribute is None, converts it to the specified type, then stores * the value and returns a pointer to the stored value or NULL if it doesn't exist or fails. - * If conversion cannot occur a python exception is set (check PyExc_Occured()) */ + * If conversion cannot occur a python exception is set (check PyExc_Occurred()) */ uint64_t *PyObject_GetAsOptionalUint64( PyObject *o, const char *class_name, diff --git a/test/test_s3.py b/test/test_s3.py index c354e258f..9d3168725 100644 --- a/test/test_s3.py +++ b/test/test_s3.py @@ -90,7 +90,7 @@ def test_cross_proc(self): process = Process(target=cross_proc_task) process.start() process.join() - # aquiring this lock in a sub-process should fail since we + # acquiring this lock in a sub-process should fail since we # already hold the lock in this process. self.assertNotEqual(0, process.exitcode)