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 3a50d9a commit 1bc819eCopy full SHA for 1bc819e
pyres/decorators.py
@@ -0,0 +1,26 @@
1
+from pyres import ResQ
2
+
3
+def job(queue, resq=ResQ(),debug=False):
4
+ def wrapper(func):
5
+ def enqueue(*args):
6
+ if not debug:
7
+ class_name = '%s.%s' % (func.__module__, func.__name__)
8
+ resq.enqueue_from_string(class_name, queue, *args)
9
+ else:
10
+ return func(*args)
11
12
+ def __call__(self, *args):
13
14
15
+ new_class = type('Job',(),{
16
+ 'queue': queue,
17
+ 'perform': staticmethod(func),
18
+ 'enqueue': staticmethod(enqueue),
19
+ '__call__': __call__,
20
+ '__name__': func.__name__
21
+ })
22
+ return new_class()
23
+ return wrapper
24
25
26
0 commit comments