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 88e679a commit e492635Copy full SHA for e492635
services/storage/src/simcore_service_storage/modules/celery/backends/_redis.py
@@ -91,7 +91,6 @@ async def list_tasks(self, task_context: TaskContext) -> list[Task]:
91
search_key_len = len(search_key)
92
93
keys: list[str] = []
94
-
95
pipeline = self._redis_client_sdk.redis.pipeline()
96
async for key in self._redis_client_sdk.redis.scan_iter(
97
match=search_key + "*", count=_CELERY_TASK_SCAN_COUNT_PER_BATCH
@@ -103,7 +102,6 @@ async def list_tasks(self, task_context: TaskContext) -> list[Task]:
103
102
else key
104
)
105
keys.append(_key)
106
107
pipeline.hget(_key, _CELERY_TASK_METADATA_KEY)
108
109
results = await pipeline.execute()
0 commit comments