typo

Author: Andrei Neagu

packages/service-library/src/servicelib/long_running_tasks/_redis_store.py

@@ -126,7 +126,7 @@ async def mark_task_for_removal(
             )
         )
 
-    async def is_maked_for_removal(self, task_id: TaskId) -> bool:
+    async def is_marked_for_removal(self, task_id: TaskId) -> bool:
         result: bool = await handle_redis_returns_union_types(
             self._redis.hexists(self._get_key_to_remove(), task_id)
         )

packages/service-library/src/servicelib/long_running_tasks/task.py

@@ -435,7 +435,7 @@ async def get_task_status(
 
         raises TaskNotFoundError if the task cannot be found
         """
-        if exclude_removed and await self._tasks_data.is_maked_for_removal(task_id):
+        if exclude_removed and await self._tasks_data.is_marked_for_removal(task_id):
             raise TaskNotFoundError(task_id=task_id)
 
         task_data = await self._get_tracked_task(task_id, with_task_context)
@@ -472,7 +472,7 @@ async def get_task_result(
         raises TaskNotFoundError if the task cannot be found
         raises TaskNotCompletedError if the task is not completed
         """
-        if await self._tasks_data.is_maked_for_removal(task_id):
+        if await self._tasks_data.is_marked_for_removal(task_id):
             raise TaskNotFoundError(task_id=task_id)
 
         tracked_task = await self._get_tracked_task(task_id, with_task_context)
@@ -502,7 +502,7 @@ async def remove_task(
         cancels and removes task
         raises TaskNotFoundError if the task cannot be found
         """
-        if await self._tasks_data.is_maked_for_removal(task_id):
+        if await self._tasks_data.is_marked_for_removal(task_id):
             raise TaskNotFoundError(task_id=task_id)
 
         tracked_task = await self._get_tracked_task(task_id, with_task_context)

packages/service-library/tests/long_running_tasks/test_long_running_tasks__store.py

@@ -52,11 +52,11 @@ async def test_workflow(store: RedisStore, task_data: TaskData) -> None:
     # cancelled tasks
     assert await store.list_tasks_to_remove() == {}
 
-    assert await store.is_maked_for_removal(task_data.task_id) is False
+    assert await store.is_marked_for_removal(task_data.task_id) is False
 
     await store.mark_task_for_removal(task_data.task_id, task_data.task_context)
 
-    assert await store.is_maked_for_removal(task_data.task_id) is True
+    assert await store.is_marked_for_removal(task_data.task_id) is True
 
     assert await store.list_tasks_to_remove() == {
         task_data.task_id: task_data.task_context