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 d1714fd commit 67ec039Copy full SHA for 67ec039
services/storage/src/simcore_service_storage/api/rpc/_async_jobs.py
@@ -17,7 +17,7 @@
17
from servicelib.rabbitmq import RPCRouter
18
19
from ...modules.celery._utils import get_celery_client
20
-from ...modules.celery.models import TaskStatus, TaskUUID
+from ...modules.celery.models import TaskStatus
21
22
router = RPCRouter()
23
@@ -73,7 +73,7 @@ async def list_jobs(
73
) -> list[AsyncJobGet]:
74
assert app # nosec
75
76
- task_uuids: set[TaskUUID] = await get_celery_client(app).get_task_uuids(
+ task_uuids = await get_celery_client(app).get_task_uuids(
77
task_context=job_id_data.model_dump(),
78
)
79
0 commit comments