Changeset View
Changeset View
Standalone View
Standalone View
swh/lister/bitbucket/tasks.py
Show All 29 Lines | |||||
@app.task(name=__name__ + '.FullBitBucketRelister', bind=True) | @app.task(name=__name__ + '.FullBitBucketRelister', bind=True) | ||||
def full_bitbucket_relister(self, split=None, **lister_args): | def full_bitbucket_relister(self, split=None, **lister_args): | ||||
lister = new_lister(**lister_args) | lister = new_lister(**lister_args) | ||||
ranges = lister.db_partition_indices(split or GROUP_SPLIT) | ranges = lister.db_partition_indices(split or GROUP_SPLIT) | ||||
random.shuffle(ranges) | random.shuffle(ranges) | ||||
promise = group(range_bitbucket_lister.s(minv, maxv, **lister_args) | promise = group(range_bitbucket_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))) | ||||
try: | try: | ||||
promise.save() # so that we can restore the GroupResult in tests | promise.save() # so that we can restore the GroupResult in tests | ||||
except (NotImplementedError, AttributeError): | except (NotImplementedError, AttributeError): | ||||
self.log.info('Unable to call save_group with current result backend.') | self.log.info('Unable to call save_group with current result backend.') | ||||
return promise.id | return promise.id | ||||
@app.task(name=__name__ + '.ping') | @app.task(name=__name__ + '.ping') | ||||
def ping(): | def ping(): | ||||
return 'OK' | return 'OK' |