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 8d855c3 commit ad65bf3Copy full SHA for ad65bf3
services/storage/src/simcore_service_storage/modules/celery/backends/_redis.py
@@ -59,10 +59,10 @@ async def remove(self, task_id: TaskID) -> None:
59
AsyncResult(_CELERY_TASK_META_PREFIX + task_id).forget()
60
61
async def set(
62
- self, task_id: TaskID, task_data: TaskMetadata, expiry: timedelta
+ self, task_id: TaskID, task_metadata: TaskMetadata, expiry: timedelta
63
) -> None:
64
await self._redis_client_sdk.redis.set(
65
_CELERY_TASK_METADATA_PREFIX + task_id,
66
- task_data.model_dump_json(),
+ task_metadata.model_dump_json(),
67
ex=expiry,
68
)
0 commit comments