| 95 | ) |
| 96 | |
| 97 | def import_default_modules(self): |
| 98 | responses = signals.import_modules.send(sender=self.app) |
| 99 | # Prior to this point loggers are not yet set up properly, need to |
| 100 | # check responses manually and reraised exceptions if any, otherwise |
| 101 | # they'll be silenced, making it incredibly difficult to debug. |
| 102 | for _, response in responses: |
| 103 | if isinstance(response, Exception): |
| 104 | raise response |
| 105 | return [self.import_task_module(m) for m in self.default_modules] |
| 106 | |
| 107 | def init_worker(self): |
| 108 | if not self.worker_initialized: |