Switch to unified view
| a/Allura/allura/command/taskd.py | b/Allura/allura/command/taskd.py | ||
|---|---|---|---|
... |
... |
||
| 84 | def check_running(func): |
84 | def check_running(func): |
| 85 | def waitfunc_checks_running(): |
85 | def waitfunc_checks_running(): |
| 86 | if self.keep_running: |
86 | if self.keep_running: |
| 87 | return func() |
87 | return func() |
| 88 | else: |
88 | else: |
| 89 | return None |
89 | raise StopIteration |
| 90 | return waitfunc_checks_running |
90 | return waitfunc_checks_running |
| 91 | 91 | ||
| 92 | if pylons.g.amq_conn: |
92 | if pylons.g.amq_conn: |
| 93 | waitfunc = waitfunc_amqp |
93 | waitfunc = waitfunc_amqp |
| 94 | else: |
94 | else: |