Skip to content

Commit 9a96dd8

Browse files
fix get_uuids
1 parent 87fb925 commit 9a96dd8

File tree

1 file changed

+2
-1
lines changed
  • services/storage/src/simcore_service_storage/modules/celery

1 file changed

+2
-1
lines changed

services/storage/src/simcore_service_storage/modules/celery/client.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,7 @@ def get_task_uuids(self, task_context: TaskContext) -> set[TaskUUID]:
135135
self._celery_app.control.inspect(), task_inspect_status
136136
)():
137137
for values in task_ids.values():
138-
all_task_ids.add(values)
138+
for value in values:
139+
all_task_ids.add(TaskUUID(value.decode(_CELERY_TASK_ID_KEY_ENCODING)))
139140

140141
return all_task_ids

0 commit comments

Comments
 (0)