fix: typo

Author: giancarloromeo

packages/celery-library/src/celery_library/errors.py

@@ -11,7 +11,7 @@ def __str__(self) -> str:
         return f"{decode_celery_transferrable_error(self)}"
 
 
-def encore_celery_transferrable_error(error: Exception) -> TransferrableCeleryError:
+def encode_celery_transferrable_error(error: Exception) -> TransferrableCeleryError:
     # NOTE: Celery modifies exceptions during serialization, which can cause
     # the original error context to be lost. This mechanism ensures the same
     # error can be recreated on the caller side exactly as it was raised here.

packages/celery-library/src/celery_library/task.py

@@ -16,7 +16,7 @@
 from servicelib.async_utils import cancel_wait_task
 
 from . import get_event_loop
-from .errors import encore_celery_transferrable_error
+from .errors import encode_celery_transferrable_error
 from .models import TaskID
 from .utils import get_fastapi_app
 
@@ -120,7 +120,7 @@ def wrapper(task: AbortableTask, *args: P.args, **kwargs: P.kwargs) -> R:
                 if isinstance(exc, dont_autoretry_for):
                     _logger.debug("Not retrying for exception %s", type(exc).__name__)
                     # propagate without retry
-                    raise encore_celery_transferrable_error(exc) from exc
+                    raise encode_celery_transferrable_error(exc) from exc
 
                 exc_type = type(exc).__name__
                 exc_message = f"{exc}"
@@ -134,7 +134,7 @@ def wrapper(task: AbortableTask, *args: P.args, **kwargs: P.kwargs) -> R:
                 raise task.retry(
                     max_retries=max_retries,
                     countdown=delay_between_retries.total_seconds(),
-                    exc=encore_celery_transferrable_error(exc),
+                    exc=encode_celery_transferrable_error(exc),
                 ) from exc
 
         return wrapper

packages/celery-library/tests/unit/test_errors.py

@@ -1,7 +1,7 @@
 import pytest
 from celery_library.errors import (
     decode_celery_transferrable_error,
-    encore_celery_transferrable_error,
+    encode_celery_transferrable_error,
 )
 from models_library.api_schemas_storage.export_data_async_jobs import AccessRightError
 
@@ -17,7 +17,7 @@ def test_workflow(original_error: Exception):
     try:
         raise original_error  # noqa: TRY301
     except Exception as e:  # pylint: disable=broad-exception-caught
-        result = encore_celery_transferrable_error(e)
+        result = encode_celery_transferrable_error(e)
 
         assert decode_celery_transferrable_error(result).args == original_error.args
         assert f"{decode_celery_transferrable_error(result)}" == f"{original_error}"