diff --git a/python/ray/autoscaler/_private/commands.py b/python/ray/autoscaler/_private/commands.py
index 3c5e71ae4..9f5a2d0f1 100644
--- a/python/ray/autoscaler/_private/commands.py
+++ b/python/ray/autoscaler/_private/commands.py
@@ -305,7 +305,7 @@ def teardown_cluster(config_file: str, yes: bool, workers_only: bool,
             # todo: add better exception info
             cli_logger.verbose_error("{}", str(e))
             cli_logger.warning(
-                "Exception occured when stopping the cluster Ray runtime "
+                "Exception occurred when stopping the cluster Ray runtime "
                 "(use -v to dump teardown exceptions).")
             cli_logger.warning(
                 "Ignoring the exception and "
diff --git a/python/ray/dashboard/metrics_exporter/client.py b/python/ray/dashboard/metrics_exporter/client.py
index 9b3eabb6e..88be328d8 100644
--- a/python/ray/dashboard/metrics_exporter/client.py
+++ b/python/ray/dashboard/metrics_exporter/client.py
@@ -142,6 +142,7 @@ class Exporter(threading.Thread):
                             self.dashboard_controller.tune_info(),
                             self.dashboard_controller.tune_availability())
             except Exception as e:
-                logger.error("Exception occured while exporting metrics: {}.\n"
-                             "Traceback: {}".format(e, traceback.format_exc()))
+                logger.error(
+                    "Exception occurred while exporting metrics: {}.\n"
+                    "Traceback: {}".format(e, traceback.format_exc()))
                 continue
diff --git a/python/ray/tune/function_runner.py b/python/ray/tune/function_runner.py
index 9f1550916..b55c4b6bf 100644
--- a/python/ray/tune/function_runner.py
+++ b/python/ray/tune/function_runner.py
@@ -340,7 +340,7 @@ class FunctionRunner(Trainable):
             except queue.Empty:
                 pass
 
-        # check if error occured inside the thread runner
+        # check if error occurred inside the thread runner
         if result is None:
             # only raise an error from the runner if all results are consumed
             self._report_thread_runner_error(block=True)
diff --git a/python/ray/worker.py b/python/ray/worker.py
index 7ac2fa8c7..3b66dbc1c 100644
--- a/python/ray/worker.py
+++ b/python/ray/worker.py
@@ -1005,7 +1005,8 @@ def print_logs(redis_client, threads_stopped, job_id):
 def print_error_messages_raylet(task_error_queue, threads_stopped):
     """Prints message received in the given output queue.
 
-    This checks periodically if any un-raised errors occured in the background.
+    This checks periodically if any un-raised errors occurred in the
+    background.
 
     Args:
         task_error_queue (queue.Queue): A queue used to receive errors from the