(self)
| 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: |
| 109 | self.worker_initialized = True |
| 110 | self.import_default_modules() |
| 111 | self.on_worker_init() |
| 112 | |
| 113 | def shutdown_worker(self): |
| 114 | self.on_worker_shutdown() |