Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/gitlab/tasks.py
| Show First 20 Lines • Show All 51 Lines • ▼ Show 20 Lines | self.log.debug('%s, lister_args=%s' % ( | ||||
| self.name, lister_args)) | self.name, lister_args)) | ||||
| lister = new_lister(**lister_args) | lister = new_lister(**lister_args) | ||||
| _, total_pages, _ = lister.get_pages_information() | _, total_pages, _ = lister.get_pages_information() | ||||
| ranges = list(utils.split_range(total_pages, NBPAGES)) | ranges = list(utils.split_range(total_pages, NBPAGES)) | ||||
| random.shuffle(ranges) | random.shuffle(ranges) | ||||
| group(range_gitlab_lister.s(minv, maxv, **lister_args) | group(range_gitlab_lister.s(minv, maxv, **lister_args) | ||||
| for minv, maxv in ranges)() | for minv, maxv in ranges)() | ||||
| self.log.debug('%s OK (spawned %s subtasks)' % (self.name, len(ranges))) | self.log.debug('%s OK (spawned %s subtasks)' % (self.name, len(ranges))) | ||||
| @app.task(name='swh.lister.gitlab.tasks.ping', | |||||
| base=SWHTask, bind=True) | |||||
| def ping(self): | |||||
| self.log.debug(self.name) | |||||
| return 'OK' | |||||