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 65a07e0 commit 327c8f1Copy full SHA for 327c8f1
services/storage/src/simcore_service_storage/modules/celery/_common.py
@@ -2,6 +2,7 @@
2
from functools import wraps
3
import logging
4
import traceback
5
+from typing import Any
6
7
from celery import Celery, Task
8
from celery.exceptions import Ignore
@@ -30,9 +31,9 @@ def create_app(celery_settings: CelerySettings) -> Celery:
30
31
return app
32
33
-def error_handling(func: Callable):
34
+def error_handling(func: Callable[..., Any]) -> Callable[..., Any]:
35
@wraps(func)
- def wrapper(task: Task, *args, **kwargs):
36
+ def wrapper(task: Task, *args: Any, **kwargs: Any) -> Any:
37
try:
38
return func(task, *args, **kwargs)
39
except Exception as exc:
0 commit comments