We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd4c535 commit 65557cbCopy full SHA for 65557cb
services/storage/src/simcore_service_storage/modules/celery/client.py
@@ -92,7 +92,10 @@ async def get_task_result(
92
task_id = build_task_id(task_context, task_uuid)
93
async_result = self._celery_app.AsyncResult(task_id)
94
result = async_result.result
95
- if async_result.ready() and (await self._task_store.get(task_id)).ephemeral:
+ if async_result.ready():
96
+ task_metadata = await self._task_store.get(task_id)
97
+ if task_metadata is not None and task_metadata.ephemeral:
98
+ await self._task_store.remove(task_id)
99
await self._task_store.remove(task_id)
100
return result
101
0 commit comments