(self)
| 158 | self.app.loader.shutdown_worker() |
| 159 | |
| 160 | def on_stopped(self): |
| 161 | self.timer.stop() |
| 162 | self.consumer.shutdown() |
| 163 | |
| 164 | if self.pidlock: |
| 165 | self.pidlock.release() |
| 166 | |
| 167 | def setup_queues(self, include, exclude=None): |
| 168 | include = str_to_list(include) |