(avro) branch main updated: fix 'occured' -> 'occurred' typos in error messages across C# and Python IPC (#3733)

[mg...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mgrigorov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/avro.git


The following commit(s) were added to refs/heads/main by this push:
     new fc9e4e7a6a fix 'occured' -> 'occurred' typos in error messages across C# and Python IPC (#3733)
fc9e4e7a6a is described below

commit fc9e4e7a6a17b622c776a9b449fbead1ba3c5d50
Author: Sai Asish Y <sa...@gmail.com>
AuthorDate: Fri Apr 17 02:07:24 2026 -0700

    fix 'occured' -> 'occurred' typos in error messages across C# and Python IPC (#3733)
    
    - lang/csharp/.../HttpListenerServer.cs: Debug.Print message in the
      HTTP listener when the per-request handler throws.
    - lang/py/.../tether/tether_task_runner.py: two log.error messages
      emitted from TetherTaskRunner.process_message when the partition
      message fails to parse or any other exception propagates.
    - lang/py/.../tether/tether_task.py: two log messages emitted from
      TetherTask.fail when the task reports failure / fails to send the
      fail message back to the output server.
    
    No functional changes.
    
    Signed-off-by: Sai Asish Y <sa...@gmail.com>
---
 lang/csharp/src/apache/ipc/HttpListenerServer.cs | 2 +-
 lang/py/avro/tether/tether_task.py               | 4 ++--
 lang/py/avro/tether/tether_task_runner.py        | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/lang/csharp/src/apache/ipc/HttpListenerServer.cs b/lang/csharp/src/apache/ipc/HttpListenerServer.cs
index 9bd03d2975..21d1759717 100644
--- a/lang/csharp/src/apache/ipc/HttpListenerServer.cs
+++ b/lang/csharp/src/apache/ipc/HttpListenerServer.cs
@@ -77,7 +77,7 @@ namespace Avro.ipc
                 //    ExceptionHandler(ex, result);
                 //else
                 //    Debug.Print("Exception occured while processing a request, no exception handler was provided - ignoring", ex);
-                Debug.Print("Exception occured while processing a web request, skipping this request: ", ex);
+                Debug.Print("Exception occurred while processing a web request, skipping this request: ", ex);
             }
         }
 
diff --git a/lang/py/avro/tether/tether_task.py b/lang/py/avro/tether/tether_task.py
index 884790e4e6..8d16b92b21 100644
--- a/lang/py/avro/tether/tether_task.py
+++ b/lang/py/avro/tether/tether_task.py
@@ -422,7 +422,7 @@ class TetherTask(abc.ABC):
         """
         Call to fail the task.
         """
-        self.log.error("TetherTask.fail: failure occured message follows:\n%s", message)
+        self.log.error("TetherTask.fail: failure occurred message follows:\n%s", message)
         try:
             message = message.decode()
         except AttributeError:
@@ -431,7 +431,7 @@ class TetherTask(abc.ABC):
         try:
             self.outputClient.request("fail", {"message": message})
         except Exception:
-            self.log.exception("TetherTask.fail: an exception occured while trying to send the fail message to the output server.")
+            self.log.exception("TetherTask.fail: an exception occurred while trying to send the fail message to the output server.")
 
         self.close()
 
diff --git a/lang/py/avro/tether/tether_task_runner.py b/lang/py/avro/tether/tether_task_runner.py
index bd98cb4633..481b3c620a 100644
--- a/lang/py/avro/tether/tether_task_runner.py
+++ b/lang/py/avro/tether/tether_task_runner.py
@@ -67,7 +67,7 @@ class TaskRunnerResponder(avro.ipc.Responder):
                 try:
                     self.task.partitions = request["partitions"]
                 except Exception:
-                    self.log.error("Exception occured while processing the partitions message: Message:\n%s", traceback.format_exc())
+                    self.log.error("Exception occurred while processing the partitions message: Message:\n%s", traceback.format_exc())
                     raise
             elif message.name == "input":
                 self.log.info("TetherTaskRunner: Received input")
@@ -84,7 +84,7 @@ class TaskRunnerResponder(avro.ipc.Responder):
                 self.log.warning("TetherTaskRunner: Received unknown message %s", message.name)
 
         except Exception:
-            self.log.error("Error occured while processing message: %s", message.name)
+            self.log.error("Error occurred while processing message: %s", message.name)
             e = traceback.format_exc()
             self.task.fail(e)