(self, includes)
| 181 | self.app.amqp.queues.select_add(worker_direct(self.hostname)) |
| 182 | |
| 183 | def setup_includes(self, includes): |
| 184 | # Update celery_include to have all known task modules, so that we |
| 185 | # ensure all task modules are imported in case an execv happens. |
| 186 | prev = tuple(self.app.conf.include) |
| 187 | if includes: |
| 188 | prev += tuple(includes) |
| 189 | [self.app.loader.import_task_module(m) for m in includes] |
| 190 | self.include = includes |
| 191 | task_modules = {task.__class__.__module__ |
| 192 | for task in self.app.tasks.values()} |
| 193 | self.app.conf.include = tuple(set(prev) | task_modules) |
| 194 | |
| 195 | def prepare_args(self, **kwargs): |
| 196 | return kwargs |
no test coverage detected