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 c21fadf commit 8cc0d5cCopy full SHA for 8cc0d5c
scheduler/decorators.py
@@ -7,7 +7,7 @@
7
JOB_METHODS_LIST: List[str] = list()
8
9
10
-class _job:
+class job:
11
def __init__(
12
self,
13
queue: Union["Queue", str, None] = None, # noqa: F821
@@ -96,21 +96,3 @@ def delay(*args, **kwargs):
96
JOB_METHODS_LIST.append(f"{f.__module__}.{f.__name__}")
97
f.delay = delay
98
return f
99
-
100
101
-def job(
102
- func_or_queue: Union[FunctionReferenceType, str],
103
- *args: Any,
104
- **kwargs: Any,
105
-) -> _job:
106
- if callable(func_or_queue):
107
- func = func_or_queue
108
- queue_name: str = "default"
109
- else:
110
- func = None
111
- queue_name = func_or_queue
112
113
- decorator = _job(queue_name, *args, **kwargs)
114
- if func:
115
- return decorator(func)
116
- return decorator
0 commit comments