Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/tests/tasks.py
| Show All 19 Lines | @app.task(name='swh.scheduler.tests.tasks.multiping', | ||||
| bind=True) | bind=True) | ||||
| def multiping(self, n=10): | def multiping(self, n=10): | ||||
| self.log.debug(self.name) | self.log.debug(self.name) | ||||
| promise = group(ping.s(i=i) for i in range(n))() | promise = group(ping.s(i=i) for i in range(n))() | ||||
| self.log.debug('%s OK (spawned %s subtasks)' % (self.name, n)) | self.log.debug('%s OK (spawned %s subtasks)' % (self.name, n)) | ||||
| promise.save() | promise.save() | ||||
| return promise.id | return promise.id | ||||
| @app.task(name='swh.scheduler.tests.tasks.error', | |||||
| bind=True) | |||||
| def not_implemented(self): | |||||
| self.log.debug(self.name) | |||||
| raise NotImplementedError('Nope') | |||||
| @app.task(name='swh.scheduler.tests.tasks.add', | |||||
| bind=True) | |||||
| def add(self, x, y): | |||||
| self.log.debug(self.name) | |||||
| return x + y | |||||