Skip to content

Commit 9336de9

Browse files
fix: removal order
1 parent 08927df commit 9336de9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,8 @@ async def cancel_task(self, task_filter: TaskFilter, task_uuid: TaskUUID) -> Non
7474
msg=f"task cancellation: {task_filter=} {task_uuid=}",
7575
):
7676
task_id = build_task_id(task_filter, task_uuid)
77-
await self._forget_task(task_id)
7877
await self._task_info_store.remove_task(task_id)
78+
await self._forget_task(task_id)
7979

8080
async def exists_task(self, task_id: TaskID) -> bool:
8181
return await self._task_info_store.exists_task(task_id)
@@ -98,8 +98,8 @@ async def get_task_result(
9898
if async_result.ready():
9999
task_metadata = await self._task_info_store.get_task_metadata(task_id)
100100
if task_metadata is not None and task_metadata.ephemeral:
101-
await self._forget_task(task_id)
102101
await self._task_info_store.remove_task(task_id)
102+
await self._forget_task(task_id)
103103
return result
104104

105105
async def _get_task_progress_report(

0 commit comments

Comments
 (0)