(self)
| 71 | raise |
| 72 | |
| 73 | def start(self): |
| 74 | if self.logger_queue: |
| 75 | handler = self.QueueHandler(self.logger_queue) |
| 76 | handler.addFilter(lambda r: r.process != self.pid and not getattr(r, 'from_queue', False)) |
| 77 | logger = logging.getLogger() |
| 78 | logger.addHandler(handler) |
| 79 | return super().start() |
| 80 | |
| 81 | def on_consumer_ready(self, consumer): |
| 82 | # type: (celery.worker.consumer.Consumer) -> None |
no outgoing calls
no test coverage detected